Examples of flex.messaging.MessageBroker.routeMessageToService()

flex.messaging.MessageBroker.routeMessageToService()
You can call this method in order to send a message from your code into the message routing system. The message is routed to a service that is defined to handle messages of this type. Once the service is identified, the destination property of the message is used to find a destination configured for that service. The adapter defined for that destination is used to handle the message. @param message The message to be routed to a service @param endpoint This can identify the endpoint that is sending the messagebut it is currently not used so you may pass in null. @return AcknowledgeMessage with result.

        msg.setDestination(destination);
        msg.setClientId(clientID);
        msg.setMessageId(UUIDUtils.createUUID(false));
        msg.setTimestamp(System.currentTimeMillis());
        msg.setBody(message);
        msgBroker.routeMessageToService(msg, null);         
    }


    public void publishAcknowledgeMessage(String destination, String message)
    {
        MessageBroker msgBroker = getMessageBroker();

View Full Code Here

        msg.setDestination(destination);
        msg.setClientId(clientID);
        msg.setMessageId(UUIDUtils.createUUID(false));
        msg.setTimestamp(System.currentTimeMillis());
        msg.setBody(message);
        msgBroker.routeMessageToService(msg, null);
    }


    public void publishMessageWithHeader(String destination, String message, String headerName, String headerValue)
    {
        MessageBroker msgBroker = getMessageBroker();

View Full Code Here

        msg.setClientId(clientID);
        msg.setMessageId(UUIDUtils.createUUID(false));
        msg.setTimestamp(System.currentTimeMillis());
        msg.setBody(message);
        msg.setHeader(headerName, headerValue);
        msgBroker.routeMessageToService(msg, null);         
    }
    private MessageBroker getMessageBroker() 
    {
        return FlexContext.getMessageBroker();
    }

View Full Code Here

        msg.setDestination(destination);
        msg.setClientId(clientID);
        msg.setMessageId(UUIDUtils.createUUID(false));
        msg.setTimestamp(System.currentTimeMillis());
        msg.setBody(EnumApple.A);
        msgBroker.routeMessageToService(msg, null);         
    }
    
}

View Full Code Here

        msg.setHeader("DSSubtopic", stock.getSymbol());
        msg.setClientId(clientID);
        msg.setMessageId(UUIDUtils.createUUID());
        msg.setTimestamp(System.currentTimeMillis());
        msg.setBody(stock);
        msgBroker.routeMessageToService(msg, null);


        try {
          Thread.sleep(20);
        } catch (InterruptedException e) {
        }

View Full Code Here

        msg.setDestination("feed");
        msg.setClientId(clientID);
        msg.setMessageId(UUIDUtils.createUUID());
        msg.setTimestamp(System.currentTimeMillis());
        msg.setBody(new Double(currentValue));
        msgBroker.routeMessageToService(msg, null);


        System.out.println("" + currentValue);


        try {
          Thread.sleep(300);

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.