Package org.apache.activemq.command

Examples of org.apache.activemq.command.ActiveMQTempTopic

29
30
31
32
33
34
35
36
37
public class ActiveMQTempTopicTest extends ActiveMQTempDestinationTestSupport {

    public static final ActiveMQTempTopicTest SINGLETON = new ActiveMQTempTopicTest();

    public Object createObject() throws Exception {
        ActiveMQTempTopic info = new ActiveMQTempTopic();
        populateObject(info);
        return info;
    }
View Full Code Here
36
37
38
39
40
41
42
43
        return info;
    }

    protected void populateObject(Object object) throws Exception {
        super.populateObject(object);
        ActiveMQTempTopic info = (ActiveMQTempTopic)object;

    }
View Full Code Here
31
32
33
34
35
36
37
38
39
public class ActiveMQTempTopicTest extends ActiveMQTempDestinationTestSupport {

    public static final ActiveMQTempTopicTest SINGLETON = new ActiveMQTempTopicTest();

    public Object createObject() throws Exception {
        ActiveMQTempTopic info = new ActiveMQTempTopic();
        populateObject(info);
        return info;
    }
View Full Code Here
38
39
40
41
42
43
44
45
        return info;
    }

    protected void populateObject(Object object) throws Exception {
        super.populateObject(object);
        ActiveMQTempTopic info = (ActiveMQTempTopic)object;

    }
View Full Code Here
1084
1085
1086
1087
1088
1089
1090
1091
1092
1093
        case TOPIC:
            return new ActiveMQTopic(name);
        case TEMP_QUEUE:
            return new ActiveMQTempQueue(name);
        case TEMP_TOPIC:
            return new ActiveMQTempTopic(name);
        default:
            throw new IllegalArgumentException("Not in the valid destination format");
        }
    }
View Full Code Here
77
78
79
80
81
82
83
84
85
86
87
            } 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) {
                    activeMQDestination = new ActiveMQQueue(((Queue)destination).getQueueName());
                } else if (destination instanceof Topic) {
                    activeMQDestination = new ActiveMQTopic(((Topic)destination).getTopicName());
                }
View Full Code Here
2048
2049
2050
2051
2052
2053
2054
2055
2056
2057
2058
    protected ActiveMQTempDestination createTempDestination(boolean topic) throws JMSException {

        // 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();
View Full Code Here
564
565
566
567
568
569
570
571
572
573
        case TOPIC:
            return new ActiveMQTopic(name);
        case TEMP_QUEUE:
            return new ActiveMQTempQueue(name);
        case TEMP_TOPIC:
            return new ActiveMQTempTopic(name);
        default:   
            throw new IllegalArgumentException("Not in the valid destination format");
        }
    }
View Full Code Here
1194
1195
1196
1197
1198
1199
1200
1201
1202
     * @since 1.1
     */
    public Topic createTopic(String topicName) throws JMSException {
        checkClosed();
        if (topicName.startsWith(ActiveMQDestination.TEMP_DESTINATION_NAME_PREFIX)) {
            return new ActiveMQTempTopic(topicName);
        }
        return new ActiveMQTopic(topicName);
    }
View Full Code Here
1207
1208
1209
1210
1211
1212
1213
1214
1215
     * @since 1.1
     */
    public Topic createTopic(String topicName) throws JMSException {
        checkClosed();
        if (topicName.startsWith(ActiveMQDestination.TEMP_DESTINATION_NAME_PREFIX)) {
            return new ActiveMQTempTopic(topicName);
        }
        return new ActiveMQTopic(topicName);
    }
View Full Code Here
TOP

Related Classes of org.apache.activemq.command.ActiveMQTempTopic

  • org.apache.activemq.ActiveMQConnection
  • org.apache.activemq.ActiveMQMessageTransformation
  • org.apache.activemq.ActiveMQSession
  • org.apache.activemq.advisory.DestinationSource
  • org.apache.activemq.command.ActiveMQDestinationTest
  • org.apache.activemq.MessageTransformationTest
  • org.apache.activemq.openwire.v1.ActiveMQTempTopicMarshaller
  • org.apache.activemq.openwire.v1.ActiveMQTempTopicTest
  • org.apache.activemq.openwire.v2.ActiveMQTempTopicMarshaller
  • org.apache.activemq.openwire.v2.ActiveMQTempTopicTest
    • Copyright © 2018 www.massapicom. 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.