Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- public String sendMessage( String clientId, String message )
- {
- try
- {
- MessageBroker msgBroker = MessageBroker.getMessageBroker(null);
- MessageService msgService= (MessageService)msgBroker.getServices().get("message-service");
- Set<Object> clients = new HashSet<Object>();
- clients.add( clientId );
- AsyncMessage async = new AsyncMessage();
- async.setMessageId(UUIDUtils.createUUID());
- async.setClientId(UUIDUtils.createUUID());
- async.setDestination("BiosisEventService");
- async.setBody(message);
- System.out.println(clientId);
- msgService.pushMessageToClients(clients, async, false);
- }
- catch( Exception exc )
- {
- exc.printStackTrace();
- }
- return "Mensaje enviado";
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement