Advertisement
Guest User

Untitled

a guest
Jul 21st, 2017
49
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.75 KB | None | 0 0
  1. public String sendMessage( String clientId, String message )
  2. {
  3.  
  4. try
  5. {
  6. MessageBroker msgBroker = MessageBroker.getMessageBroker(null);
  7.  
  8. MessageService msgService= (MessageService)msgBroker.getServices().get("message-service");
  9.  
  10. Set<Object> clients = new HashSet<Object>();
  11. clients.add( clientId );
  12.  
  13. AsyncMessage async = new AsyncMessage();
  14. async.setMessageId(UUIDUtils.createUUID());
  15. async.setClientId(UUIDUtils.createUUID());
  16. async.setDestination("BiosisEventService");
  17. async.setBody(message);
  18.  
  19. System.out.println(clientId);
  20.  
  21. msgService.pushMessageToClients(clients, async, false);
  22.  
  23. }
  24. catch( Exception exc )
  25. {
  26. exc.printStackTrace();
  27. }
  28.  
  29.  
  30. return "Mensaje enviado";
  31. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement