Examples of org.jboss.soa.esb.listeners.gateway.DefaultESBPropertiesSetter

Package org.jboss.soa.esb.listeners.gateway

Examples of org.jboss.soa.esb.listeners.gateway.DefaultESBPropertiesSetter

org.jboss.soa.esb.listeners.gateway.DefaultESBPropertiesSetter
Default impl of ESBPropertiesSetter.
The following JMS Header fields are set on the ESB Message instance:
JMSCorrelationID -> Call.setRelatesTo URI = jms:correlationID#YYXX-123456780-GG
JMSReplyTo -> Properties( key = JMSPropertiesSetter.JMS_REPLY_TO )
JMSExpiration -> Properties( key = JMSPropertiesSetter.JMS_EXPIRATION )
JMSRedeliverd -> Properties( key = JMSPropertiesSetter.JMS_REDELIVERED )
JMSProperties -> Properties( key = propertyName ) Note: JMSCorrelationID is set as a fragment on the URI and can be retrieved like this: correlationURI.getFragment(); @author Daniel Bevenius @since 4.2

  {
    TextMessageImpl inBoundJmsMessage = new TextMessageImpl();
    inBoundJmsMessage.setJMSReplyTo( queue );


    Message esbMessage = MessageFactory.getInstance().getMessage();
    new DefaultESBPropertiesSetter().setPropertiesFromJMSMessage( inBoundJmsMessage, esbMessage );
        
    NotifyJMS notifyJMS = new NotifyQueues( new ConfigTree("test" ) );
    
    TextMessageImpl outBoundJmsMessage = new TextMessageImpl();
    notifyJMS.setJMSReplyTo( outBoundJmsMessage, esbMessage );

View Full Code Here

            context.rebind( QUEUE_NAME, queue );


            // inbound is to simulate a jms message arriving at a gateway endpoint.
            TextMessageImpl inBoundJmsMessage = new TextMessageImpl();
            inBoundJmsMessage.setJMSReplyTo( queue );
            new DefaultESBPropertiesSetter().setPropertiesFromJMSMessage( inBoundJmsMessage, msg );
        
            JMSRouter router = new JMSRouter( createConfigTree() );
            
            // outbound is to simulate a new jms message that is about to leave the ESB.
            TextMessageImpl outBoundJmsMessage = new TextMessageImpl();

View Full Code Here

TOP

Related Classes of org.jboss.soa.esb.listeners.gateway.DefaultESBPropertiesSetter

org.jboss.soa.esb.actions.routing.JMSRouterUnitTest

org.jboss.soa.esb.message.Properties

org.jboss.soa.esb.notification.NotifyJMSIntegrationTest

javax.jms.JMSException

java.net.URI

javax.jms.Destination

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.