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

Examples of org.apache.cxf.transport.jms.util.JMSSender.sendMessage()

645
646
647
648
649
650
651
652
653
654
655
            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);
            Message replyMessage = JMSUtil.receive(session, replyToDestination,
                                                   jmsMessage.getJMSMessageID(), 10000, true);
            checkReplyMessage(replyMessage, testcase);
        } catch (JMSException e) {
            throw JMSUtil.convertJmsException(e);
View Full Code Here
167
168
169
170
171
172
173
174
175
176
177
            }

            JMSSender sender = JMSFactory.createJmsSender(jmsConfig, headers);

            synchronized (exchange) {
                sender.sendMessage(closer, session, targetDest, message);
                LOG.log(Level.INFO, "client sending request message "
                    + message.getJMSMessageID() + " to " + targetDest);
                headers.setJMSMessageID(message.getJMSMessageID());
                if (correlationId == null) {
                    // Warning: We might loose the reply if it already arrived at this point
View Full Code Here
145
146
147
148
149
150
151
152
153
154
155
                                      msgType,
                                      session,
                                      correlationId, JMSConstants.JMS_SERVER_RESPONSE_HEADERS);
            JMSSender sender = JMSFactory.createJmsSender(jmsConfig, messageProperties);
            LOG.log(Level.FINE, "server sending reply: ", reply);
            sender.sendMessage(closer, session, replyTo, reply);
        } catch (JMSException ex) {
            throw JMSUtil.convertJmsException(ex);
        } finally {
            closer.close();
        }
View Full Code Here
642
643
644
645
646
647
648
649
650
651
652
            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);
            Message replyMessage = JMSUtil.receive(session, replyToDestination,
                                                   jmsMessage.getJMSMessageID(), 10000, true);
            checkReplyMessage(replyMessage, testcase);
        } catch (JMSException e) {
            throw JMSUtil.convertJmsException(e);
View Full Code Here
259
260
261
262
263
264
265
266
267
268
269
        }

        JMSSender sender = JMSFactory.createJmsSender(jmsConfig, headers);
       
        Destination targetDest = jmsConfig.getTargetDestination(session);
        sender.sendMessage(session, targetDest, message);
        String jmsMessageID = message.getJMSMessageID();
        LOG.log(Level.FINE, "client sending request message "
            + jmsMessageID + " to " + targetDest);
        headers.setJMSMessageID(jmsMessageID);
        return jmsMessageID;
View Full Code Here
158
159
160
161
162
163
164
165
166
167
168
                                      msgType,
                                      session,
                                      correlationId, JMSConstants.JMS_SERVER_RESPONSE_HEADERS);
            JMSSender sender = JMSFactory.createJmsSender(jmsConfig, messageProperties);
            LOG.log(Level.FINE, "server sending reply: ", reply);
            sender.sendMessage(session, replyTo, reply);
        } catch (JMSException ex) {
            throw JMSUtil.convertJmsException(ex);
        } finally {
            closer.close();
        }
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.