Package org.apache.activemq.transport.stomp

Examples of org.apache.activemq.transport.stomp.StompConnection.open()

28
29
30
31
32
33
34
35
36
37
38
*/
public class StompExample {

  public static void main(String args[]) throws Exception {
    StompConnection connection = new StompConnection();
    connection.open("localhost", 61613);
   
    connection.connect("system", "manager");
   
    connection.begin("tx1");
    connection.send("/queue/test", "message1");
View Full Code Here
73
74
75
76
77
78
79
80
81
82
83
                final URI UriToConnectTo = URISupport.removeQuery(transport.getConnectUri());
                
                if (UriToConnectTo.getScheme().startsWith("stomp")) {
                    LOG.info("validating alive with connection to: " + UriToConnectTo);
                    StompConnection connection = new StompConnection();
                    connection.open(UriToConnectTo.getHost(), UriToConnectTo.getPort());
                    connection.close();
                    break;
                } else if (UriToConnectTo.getScheme().startsWith("tcp")) {
                    LOG.info("validating alive with connection to: " + UriToConnectTo);
                    ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(UriToConnectTo);
View Full Code Here
100
101
102
103
104
105
106
107
108
    }

    @Test
    public void testConnectStomp_shouldConnect() throws Exception {
        StompConnection connection = new StompConnection();
        connection.open("localhost", STOMP_PORT);
        connection.close();
    }
}
View Full Code Here
272
273
274
275
276
277
278
279
280
281
282
        poll.setRequestHeader( "Cookie", jsessionid );
        httpClient.send( poll );

        // stomp client queues some messages
        StompConnection connection = new StompConnection();
        connection.open(stompUri.getHost(), stompUri.getPort());
        connection.connect("user", "password");
        HashMap<String, String> headers = new HashMap<String, String>();
        headers.put( "amq-msg-type", "text" );
        connection.send( "/queue/test", "message1", (String)null, headers );
        connection.send( "/queue/test", "message2", (String)null, headers );
View Full Code Here
335
336
337
338
339
340
341
342
343
344
345
        contentExchange.setRequestContentType( "application/x-www-form-urlencoded; charset=UTF-8" );
        httpClient.send(contentExchange);
        contentExchange.waitForDone();

        StompConnection connection = new StompConnection();
        connection.open(stompUri.getHost(), stompUri.getPort());
        connection.connect("user", "password");
        connection.subscribe( "/queue/test" );

        StompFrame message;
        String allMessageBodies = "";
View Full Code Here
108
109
110
111
112
113
114
115
116
117
118
                final URI UriToConnectTo = URISupport.removeQuery(transport.getConnectUri());

                if (UriToConnectTo.getScheme().startsWith("stomp")) {
                    LOG.info("validating alive with connection to: " + UriToConnectTo);
                    StompConnection connection = new StompConnection();
                    connection.open(UriToConnectTo.getHost(), UriToConnectTo.getPort());
                    connection.close();
                    break;
                } else if (UriToConnectTo.getScheme().startsWith("tcp")) {
                    LOG.info("validating alive with connection to: " + UriToConnectTo);
                    ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(UriToConnectTo);
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.