List of routeMessageToService() Examples

Examples of routeMessageToService()

com.reignite.messaging.server.Endpoint.routeMessageToService()
Takes the given data and passes it to an appropriate service. In the case of AMF it takes a RemotingMessage and returns an AcknowlegeMessage @param data the data to route to the service. @return the service response. @throws MessagingException
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.

Examples of com.reignite.messaging.server.Endpoint.routeMessageToService()


    Endpoint endpoint = context.getEndpoint();


    RemotingMessage remotingMessage = (RemotingMessage) messageBody.getData();
    try {
      responseBody.setData(endpoint.routeMessageToService(remotingMessage));
    } catch (MessagingException e) {
      LogWriter.error(getClass(), "Failed to route message to service: " + e, e);
      ErrorMessage errorBody = new ErrorMessage("Service destination could not be reached",
          remotingMessage.getDestination(), remotingMessage.getOperation(), remotingMessage.getParameters());
      responseBody.setData(errorBody);

View Full Code Here

Examples of flex.messaging.MessageBroker.routeMessageToService()

        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

Examples of flex.messaging.MessageBroker.routeMessageToService()

        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

Examples of flex.messaging.MessageBroker.routeMessageToService()

        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

Examples of flex.messaging.MessageBroker.routeMessageToService()

        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

Examples of flex.messaging.MessageBroker.routeMessageToService()

        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

Examples of flex.messaging.MessageBroker.routeMessageToService()

        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.