MessageProcessorProxy.m 1.4 KB

1234567891011121314151617181920212223242526272829303132333435363738
  1. // _____ _
  2. // |_ _| |_ _ _ ___ ___ _ __ __ _
  3. // | | | ' \| '_/ -_) -_) ' \/ _` |_
  4. // |_| |_||_|_| \___\___|_|_|_\__,_(_)
  5. //
  6. // Threema iOS Client
  7. // Copyright (c) 2015-2020 Threema GmbH
  8. //
  9. // This program is free software: you can redistribute it and/or modify
  10. // it under the terms of the GNU Affero General Public License, version 3,
  11. // as published by the Free Software Foundation.
  12. //
  13. // This program is distributed in the hope that it will be useful,
  14. // but WITHOUT ANY WARRANTY; without even the implied warranty of
  15. // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  16. // GNU Affero General Public License for more details.
  17. //
  18. // You should have received a copy of the GNU Affero General Public License
  19. // along with this program. If not, see <https://www.gnu.org/licenses/>.
  20. #import "MessageProcessorProxy.h"
  21. static id<MessageProcessorProtocol> messageProcessor;
  22. @implementation MessageProcessorProxy
  23. +(void)wireMessageProcessor:(id<MessageProcessorProtocol>)messageProcessorImpl {
  24. messageProcessor = messageProcessorImpl;
  25. }
  26. + (void)processIncomingMessage:(BoxedMessage*)boxmsg receivedAfterInitialQueueSend:(BOOL)receivedAfterInitialQueueSend onCompletion:(void(^)(void))onCompletion onError:(void(^)(NSError *err))onError {
  27. if (messageProcessor) {
  28. [messageProcessor processIncomingMessage:boxmsg receivedAfterInitialQueueSend:receivedAfterInitialQueueSend onCompletion:onCompletion onError:onError];
  29. }
  30. }
  31. @end