Examples of ActiveMQTempQueue

Examples of org.apache.activemq.command.ActiveMQTempQueue

57
58
59
60
61
62
63
64
65
   
    public void initCombosForTestDesintaionOptions() {
        addCombinationValues("destination", new Object[]{
                new ActiveMQQueue("TEST?k1=v1&k2=v2"),
                new ActiveMQTopic("TEST?k1=v1&k2=v2"),
                new ActiveMQTempQueue("TEST:1?k1=v1&k2=v2"),
                new ActiveMQTempTopic("TEST:1?k1=v1&k2=v2"),
        });
    }
View Full Code Here

Examples of org.apache.activemq.command.ActiveMQTempQueue

40
41
42
43
44
45
46
47
48
49
50
        case QUEUE:
            return new ActiveMQQueue(physicalName);
           
        case TEMPORARY_QUEUE:
            return new ActiveMQTempQueue(physicalName);

        case TEMPORARY_TOPIC:
            return new ActiveMQTempTopic(physicalName);

        default:
View Full Code Here

Examples of org.apache.activemq.command.ActiveMQTempQueue

1588
1589
1590
1591
1592
1593
1594
1595
1596
1597
1598
        // Check if Destination info is of temporary type.
        ActiveMQTempDestination dest;
        if( topic ) {
            dest = new ActiveMQTempTopic(info.getConnectionId(), tempDestinationIdGenerator.getNextSequenceId());
        } else {
            dest = new ActiveMQTempQueue(info.getConnectionId(), tempDestinationIdGenerator.getNextSequenceId());
        }
       
        DestinationInfo info = new DestinationInfo();
        info.setConnectionId(this.info.getConnectionId());
        info.setOperationType(DestinationInfo.ADD_OPERATION_TYPE);
View Full Code Here

Examples of org.apache.activemq.command.ActiveMQTempQueue

68
69
70
71
72
73
74
75
76
77
78
              return (ActiveMQDestination) destination;
             
            }
            else {
                if (destination instanceof TemporaryQueue) {
                  activeMQDestination = new ActiveMQTempQueue(((Queue) destination).getQueueName());
                }
                else if (destination instanceof TemporaryTopic) {
                  activeMQDestination = new ActiveMQTempTopic(((Topic) destination).getTopicName());
                }
                else if (destination instanceof Queue) {
View Full Code Here

Examples of org.apache.activemq.command.ActiveMQTempQueue

1906
1907
1908
1909
1910
1911
1912
1913
1914
1915
1916
        // Check if Destination info is of temporary type.
        ActiveMQTempDestination dest;
        if (topic) {
            dest = new ActiveMQTempTopic(info.getConnectionId(), tempDestinationIdGenerator.getNextSequenceId());
        } else {
            dest = new ActiveMQTempQueue(info.getConnectionId(), tempDestinationIdGenerator.getNextSequenceId());
        }

        DestinationInfo info = new DestinationInfo();
        info.setConnectionId(this.info.getConnectionId());
        info.setOperationType(DestinationInfo.ADD_OPERATION_TYPE);
View Full Code Here

Examples of org.apache.activemq.command.ActiveMQTempQueue

616
617
618
619
620
621
622
623
624
625
626
    }

    public ActiveMQDestination createTempQueue(String name) {
        ActiveMQDestination rc = tempDestinations.get(name);
        if( rc == null ) {
            rc = new ActiveMQTempQueue(connectionId, tempDestinationGenerator.getNextSequenceId());
            sendToActiveMQ(new DestinationInfo(connectionId, DestinationInfo.ADD_OPERATION_TYPE, rc), null);
            tempDestinations.put(name, rc);
        }
        return rc;
    }
View Full Code Here

Examples of org.apache.activemq.command.ActiveMQTempQueue

303
304
305
306
307
308
309
310
311
312
313
        // lets subscribe to a personal inbox for replies

        // Check if Destination info is of temporary type.
        if (inboxDestination == null) {
            inboxDestination = new ActiveMQTempQueue(connectionInfo.getConnectionId(), tempDestinationIdGenerator.getNextSequenceId());

            DestinationInfo info = new DestinationInfo();
            info.setConnectionId(connectionInfo.getConnectionId());
            info.setOperationType(DestinationInfo.ADD_OPERATION_TYPE);
            info.setDestination(inboxDestination);
View Full Code Here

Examples of org.apache.activemq.command.ActiveMQTempQueue

160
161
162
163
164
165
166
167
168
169
170
        ActiveMQConnectionFactory sendFactory = createConnectionFactory(a);
        ActiveMQConnection sendConnection = createConnection(sendFactory);

        ActiveMQSession sendSession = (ActiveMQSession)sendConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        MessageProducer producer = sendSession.createProducer(sendQ);
        ActiveMQTempQueue realReplyQ = (ActiveMQTempQueue) sendSession.createTemporaryQueue();
        TextMessage message = sendSession.createTextMessage("1");
        message.setJMSReplyTo(realReplyQ);
        producer.send(message);
        LOG.info("request sent");
View Full Code Here

Examples of org.apache.activemq.command.ActiveMQTempQueue

1850
1851
1852
1853
1854
1855
1856
1857
1858
1859
1860
        // Check if Destination info is of temporary type.
        ActiveMQTempDestination dest;
        if (topic) {
            dest = new ActiveMQTempTopic(info.getConnectionId(), tempDestinationIdGenerator.getNextSequenceId());
        } else {
            dest = new ActiveMQTempQueue(info.getConnectionId(), tempDestinationIdGenerator.getNextSequenceId());
        }

        DestinationInfo info = new DestinationInfo();
        info.setConnectionId(this.info.getConnectionId());
        info.setOperationType(DestinationInfo.ADD_OPERATION_TYPE);
View Full Code Here

Examples of org.apache.activemq.command.ActiveMQTempQueue

30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
        ConnectionId id = new ConnectionId(new IdGenerator().generateId());
        DestinationMap map = new DestinationMap();
        Object value = new Object();
        int count = 1000;
        for (int i = 0; i < count; i++) {
            ActiveMQTempQueue queue = new ActiveMQTempQueue(id, i);
            map.put(queue, value);
        }
        for (int i = 0; i < count; i++) {
            ActiveMQTempQueue queue = new ActiveMQTempQueue(id, i);
            map.remove(queue, value);
            Set<?> set = map.get(queue);
            assertTrue(set.isEmpty());
        }
    }
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.