Package org.apache.cxf.transport.jms.util

Examples of org.apache.cxf.transport.jms.util.ResourceCloser.register()

638
639
640
641
642
643
644
645
646
647
648
        endpointInfo.setAddress(JMSTestUtil.getFullAddress(address, broker.getBrokerURL()));
        JMSConfiguration jmsConfig = JMSConfigFactory.createFromEndpointInfo(staticBus, endpointInfo , null);
       
        ResourceCloser closer = new ResourceCloser();
        try {
            Connection connection = closer.register(JMSFactory.createConnection(jmsConfig));
            connection.start();
            Session session = closer.register(connection.createSession(false, Session.AUTO_ACKNOWLEDGE));
            Destination targetDest = jmsConfig.getTargetDestination(session);
            Destination replyToDestination = jmsConfig.getReplyToDestination(session, null);
            JMSSender sender = JMSFactory.createJmsSender(jmsConfig, null);
View Full Code Here
640
641
642
643
644
645
646
647
648
649
650
       
        ResourceCloser closer = new ResourceCloser();
        try {
            Connection connection = closer.register(JMSFactory.createConnection(jmsConfig));
            connection.start();
            Session session = closer.register(connection.createSession(false, Session.AUTO_ACKNOWLEDGE));
            Destination targetDest = jmsConfig.getTargetDestination(session);
            Destination replyToDestination = jmsConfig.getReplyToDestination(session, null);
            JMSSender sender = JMSFactory.createJmsSender(jmsConfig, null);
            Message jmsMessage = JMSTestUtil.buildJMSMessageFromTestCase(testcase, session, replyToDestination);
            sender.sendMessage(session, targetDest, jmsMessage);
View Full Code Here
133
134
135
136
137
138
139
140
141
142
143
        ResourceCloser closer = new ResourceCloser();
        try {
            if (connection == null) {
                connection = JMSFactory.createConnection(jmsConfig);
            }
            Session session = closer.register(connection.createSession(jmsConfig.isSessionTransacted(),
                                                                       Session.AUTO_ACKNOWLEDGE));
            Destination targetDest = jmsConfig.getTargetDestination(session);
           
            Destination replyToDestination = null;
            if (!exchange.isOneWay()) {
View Full Code Here
110
111
112
113
114
115
116
117
118
119
120
        final Message outMessage = exchange.getOutMessage();

        ResourceCloser closer = new ResourceCloser();
        try {
            ConnectionFactory cf = jmsConfig.getConnectionFactory();
            Connection connection = closer.register(cf.createConnection());
            Session session = closer
                .register(connection.createSession(jmsConfig.isSessionTransacted(), Session.AUTO_ACKNOWLEDGE));

            final JMSMessageHeadersType messageProperties = (JMSMessageHeadersType)outMessage
                .get(JMSConstants.JMS_SERVER_RESPONSE_HEADERS);
View Full Code Here
111
112
113
114
115
116
117
118
119
120
121
        ResourceCloser closer = new ResourceCloser();
        try {
            ConnectionFactory cf = jmsConfig.getConnectionFactory();
            Connection connection = closer.register(cf.createConnection());
            Session session = closer
                .register(connection.createSession(jmsConfig.isSessionTransacted(), Session.AUTO_ACKNOWLEDGE));

            final JMSMessageHeadersType messageProperties = (JMSMessageHeadersType)outMessage
                .get(JMSConstants.JMS_SERVER_RESPONSE_HEADERS);
            JMSMessageHeadersType inMessageProperties = (JMSMessageHeadersType)inMessage
View Full Code Here
635
636
637
638
639
640
641
642
643
644
645
        JMSConfiguration jmsConfig = oldConfig
            .createJMSConfigurationFromEndpointInfo(staticBus, endpointInfo , null, true);
       
        ResourceCloser closer = new ResourceCloser();
        try {
            Connection connection = closer.register(JMSFactory.createConnection(jmsConfig));
            connection.start();
            Session session = closer.register(connection.createSession(false, Session.AUTO_ACKNOWLEDGE));
            Destination targetDest = jmsConfig.getTargetDestination(session);
            Destination replyToDestination = jmsConfig.getReplyToDestination(session, null);
            JMSSender sender = JMSFactory.createJmsSender(jmsConfig, null);
View Full Code Here
637
638
639
640
641
642
643
644
645
646
647
       
        ResourceCloser closer = new ResourceCloser();
        try {
            Connection connection = closer.register(JMSFactory.createConnection(jmsConfig));
            connection.start();
            Session session = closer.register(connection.createSession(false, Session.AUTO_ACKNOWLEDGE));
            Destination targetDest = jmsConfig.getTargetDestination(session);
            Destination replyToDestination = jmsConfig.getReplyToDestination(session, null);
            JMSSender sender = JMSFactory.createJmsSender(jmsConfig, null);
            Message jmsMessage = JMSTestUtil.buildJMSMessageFromTestCase(testcase, session, replyToDestination);
            sender.sendMessage(closer, session, targetDest, jmsMessage);
View Full Code Here
135
136
137
138
139
140
141
142
143
144
145
        assertIsNotTextMessageAndMtom(outMessage);

        ResourceCloser closer = new ResourceCloser();
        try {
            Connection c = getConnection();
            Session session = closer.register(c.createSession(false,
                                                              Session.AUTO_ACKNOWLEDGE));
           
            if (exchange.isOneWay()) {
                sendMessage(request, outMessage, null, null, closer, session);
            } else {
View Full Code Here
111
112
113
114
115
116
117
118
119
120
121
        final Message outMessage = exchange.getOutMessage();

        ResourceCloser closer = new ResourceCloser();
        try {
            Session session = closer
                .register(connection.createSession(false, Session.AUTO_ACKNOWLEDGE));

            final JMSMessageHeadersType messageProperties = (JMSMessageHeadersType)outMessage
                .get(JMSConstants.JMS_SERVER_RESPONSE_HEADERS);
            JMSMessageHeadersType inMessageProperties = (JMSMessageHeadersType)inMessage
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.