Package javax.jms

Examples of javax.jms.Connection.start()

47
48
49
50
51
52
53
54
55
56
57
    Connection cnx = cf.createConnection();
    Session qSess = cnx.createSession(false, Session.AUTO_ACKNOWLEDGE);

    MessageConsumer qConsumer = qSess.createConsumer(queue);
    cnx.start();

    TextMessage msg;

    for (int i = 0; i < 10; i++) {
      msg = (TextMessage) qConsumer.receive();
View Full Code Here
49
50
51
52
53
54
55
56
57
58
59
    Connection cnx = cf.createConnection();
    Session sess = cnx.createSession(false, Session.AUTO_ACKNOWLEDGE);
    MessageConsumer recv = sess.createConsumer(queue);
    Message msg;

    cnx.start();

    msg = recv.receive();
     
    String u = msg.getStringProperty("url");
    System.out.println("url = " + u);
View Full Code Here
51
52
53
54
55
56
57
58
59
60
61
    Session sess = cnx.createSession(false, Session.AUTO_ACKNOWLEDGE);
    MessageConsumer sub = sess.createConsumer(topic);

    sub.setMessageListener(new Listener());

    cnx.start();

    System.in.read();

    System.out.println();
    System.out.println("Subscriber closed.");
View Full Code Here
53
54
55
56
57
58
59
60
61
62
63
    Connection cnx = cf.createConnection();
    Session sess = cnx.createSession(false, Session.AUTO_ACKNOWLEDGE);
    MessageProducer prod = sess.createProducer(queue);
    MessageConsumer cons = sess.createConsumer(queue);
    cnx.start();

    Message msg1 = sess.createMessage();
    msg1.setStringProperty("Joram#0:type=Destination,name=*",
                           "NbMsgsReceiveSinceCreation,NbMsgsSentToDMQSinceCreation");
    prod.send(msg1);
View Full Code Here
676
677
678
679
680
681
682
683
684
685
686
    //  set identity className
    cf.setIdentityClassName(identityClass);
    try {
      cnx = cf.createConnection(name, password);
      cnx.start();

      return new JoramAdmin(cnx);
    } catch (JMSSecurityException exc) {
      if (logger.isLoggable(BasicLevel.DEBUG))
        logger.log(BasicLevel.DEBUG, "JoramAdmin - error during creation", exc);
View Full Code Here
73
74
75
76
77
78
79
80
81
82
83
            } else {
                connection = tcf.createTopicConnection();
            }
        }

        connection.start();

        Destination requestDestination =
                (Destination)context.lookup(
                                           addrDetails.getJndiDestinationName());
View Full Code Here
41
42
43
44
45
46
47
48
49
50
51
        if (clientID != null) {
            connection.setClientID(clientID);
        }
       
        // lets start the connection in case that we consume on the same connection
        connection.start();

        return newInstance(connection, config);
    }

    public static DefaultJmsProducer newInstance(Connection connection, JmsProducerConfig config) throws JMSException {
View Full Code Here
81
82
83
84
85
86
87
88
89
90
91
      conn = cf.createConnection();
      session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
      MessageConsumer cons = session.createConsumer(queue);

      conn.start();

      // messages will be sent in bulk from server side, on the next HTTP client listner poll

      for(int i = 0; i < messageCount; i++)
      {
View Full Code Here
170
171
172
173
174
175
176
177
178
179
180
        
         Session sess2 = conn.createSession(false, Session.CLIENT_ACKNOWLEDGE);
        
         MessageConsumer cons = sess2.createConsumer(queue);
        
         conn.start();
        
         for (int i = 0; i < NUM_MESSAGES; i++)
         {
            TextMessage tm = (TextMessage)cons.receive(500);
           
View Full Code Here
201
202
203
204
205
206
207
208
209
210
211
  
   public void testRelayMessage() throws Exception
   {
      Connection conn = cf.createConnection();

      conn.start();

      final Session sess = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);

      MessageConsumer cons = sess.createConsumer(queue);
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.