Package org.apache.activemq

Examples of org.apache.activemq.ActiveMQConnection.createSession()

180
181
182
183
184
185
186
187
188
189
190
                clientUrl);
        for (int i = 0; i < numOfClients; i++) {
            ActiveMQConnection c = (ActiveMQConnection) factory
                    .createConnection();
            c.start();
            Session s = c.createSession(false, Session.AUTO_ACKNOWLEDGE);
            Queue queue = s.createQueue(getClass().getName());
            MessageConsumer consumer = s.createConsumer(queue);
            connections.add(c);
        }
    }
View Full Code Here
52
53
54
55
56
57
58
59
60
61
62
        // send message to dlq immediately
        RedeliveryPolicy policy = connection.getRedeliveryPolicy();
        policy.setMaximumRedeliveries(0);       
        connection.start();
       
        Session session = connection.createSession(true, Session.SESSION_TRANSACTED);
        ActiveMQQueue destination = new ActiveMQQueue("camelRedeliveryQ");
        MessageProducer producer = session.createProducer(destination);
       
        MessageConsumer consumer = session.createConsumer(destination);
        // Send the messages
View Full Code Here
108
109
110
111
112
113
114
115
116
117
118
        assertTrue("expected: compressed Size '" + compressedSize + "' < unCompressedSize '" + unCompressedSize + "'", compressedSize < unCompressedSize);
    }

    private void sendTestMessage(ActiveMQConnectionFactory factory, String message) throws JMSException {
        ActiveMQConnection connection = (ActiveMQConnection)factory.createConnection();
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        MessageProducer producer = session.createProducer(queue);
        producer.send(session.createTextMessage(message));
        connection.close();
    }
View Full Code Here
117
118
119
120
121
122
123
124
125
126
127
    }

    private ActiveMQTextMessage receiveTestMessage(ActiveMQConnectionFactory factory) throws JMSException {
        ActiveMQConnection connection = (ActiveMQConnection)factory.createConnection();
        connection.start();
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        MessageConsumer consumer = session.createConsumer(queue);
        ActiveMQTextMessage rc = (ActiveMQTextMessage)consumer.receive();
        connection.close();
        return rc;
    }
View Full Code Here
126
127
128
129
130
131
132
133
134
135
136
        return rc;
    }

    private void sendTestBytesMessage(ActiveMQConnectionFactory factory, String message) throws JMSException, UnsupportedEncodingException {
        ActiveMQConnection connection = (ActiveMQConnection)factory.createConnection();
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        MessageProducer producer = session.createProducer(queue);
        BytesMessage bytesMessage = session.createBytesMessage();
        bytesMessage.writeBytes(message.getBytes("UTF8"));
        producer.send(bytesMessage);
        connection.close();
View Full Code Here
137
138
139
140
141
142
143
144
145
146
147
    }

    private ActiveMQBytesMessage receiveTestBytesMessage(ActiveMQConnectionFactory factory) throws JMSException, UnsupportedEncodingException {
        ActiveMQConnection connection = (ActiveMQConnection)factory.createConnection();
        connection.start();
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        MessageConsumer consumer = session.createConsumer(queue);
        ActiveMQBytesMessage rc = (ActiveMQBytesMessage)consumer.receive();
        connection.close();
        return rc;
    }
View Full Code Here
57
58
59
60
61
62
63
64
65
66
67
           
          Runnable r = new Runnable() {
              public void run() {
                  try {
                    LOG.info("Sender thread starting");
                      Session session = cx.createSession(false, 1);
                      MessageProducer producer = session.createProducer(queue);
                      producer.setDeliveryMode(DeliveryMode.PERSISTENT);
                     
                      TextMessage message = session.createTextMessage(createMessageText());
                      for(int count=0; count<messageCount; count++){
View Full Code Here
101
102
103
104
105
106
107
108
109
110
111
            broker.getSystemUsage().setSendFailIfNoSpaceAfterTimeout(5000);
          Runnable r = new Runnable() {
              public void run() {
                  try {
                    LOG.info("Sender thread starting");
                      Session session = cx.createSession(false, 1);
                      MessageProducer producer = session.createProducer(queue);
                      producer.setDeliveryMode(DeliveryMode.PERSISTENT);

                      TextMessage message = session.createTextMessage(createMessageText());
                      for(int count=0; count<messageCount; count++){
View Full Code Here
131
132
133
134
135
136
137
138
139
140
141
        cf.setWatchTopicAdvisories(watchTopicAdvisories);

        final ActiveMQConnection connection = (ActiveMQConnection) cf.createConnection();
        connection.start();

        final Session consumerSession = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        final Queue destination = consumerSession.createQueue(QUEUE_NAME + "?jms.consumer.prefetch=" + prefetch);

        final Vector<TestConsumer> testConsumers = new Vector<TestConsumer>();
        for (int i=0; i<maxConsumers -1; i++) {
            testConsumers.add(new TestConsumer(consumerSession, destination, connection));
View Full Code Here
154
155
156
157
158
159
160
161
162
163
164
    protected void createClients() throws Exception {
        ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(clientUrl);
        for (int i = 0; i < NUMBER; i++) {
            ActiveMQConnection c = (ActiveMQConnection) factory.createConnection();
            c.start();
            Session s = c.createSession(false, Session.AUTO_ACKNOWLEDGE);
            Queue queue = s.createQueue(getClass().getName());
            MessageConsumer consumer = s.createConsumer(queue);
            connections.add(c);
        }
    }
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.