Java 类org.apache.camel.component.jms.JmsEndpoint 实例源码

@Test
public void testTemporaryDestinationTypes() throws Exception {
    JmsEndpoint endpoint = getMandatoryEndpoint("activemq:test.queue", JmsEndpoint.class);
    JmsConfiguration configuration = endpoint.getConfiguration();
    JmsProviderMetadata providerMetadata = configuration.getProviderMetadata();
    assertNotNull("provider", providerMetadata);

    Class<? extends TemporaryQueue> queueType = endpoint.getTemporaryQueueType();
    Class<? extends TemporaryTopic> topicType = endpoint.getTemporaryTopicType();

    log.info("Found queue type: " + queueType);
    log.info("Found topic type: " + topicType);

    assertNotNull("queueType", queueType);
    assertNotNull("topicType", topicType);

    assertEquals("queueType", ActiveMQTempQueue.class, queueType);
    assertEquals("topicType", ActiveMQTempTopic.class, topicType);
}

public ExclusiveQueueMessageListenerContainer(JmsEndpoint endpoint) {
    super(endpoint, endpoint.isAllowReplyManagerQuickStop());
}

public void setEndpoint(JmsEndpoint endpoint) {
    this.endpoint = endpoint;
}

protected void addTopic(ActiveMQTopic topic) throws Exception {
    String topicUri = getTopicUri(topic);
    ActiveMQComponent jmsComponent = getComponent();
    Endpoint endpoint = new JmsEndpoint(topicUri, jmsComponent, topic.getPhysicalName(), true, jmsComponent.getConfiguration());
    camelContext.addEndpoint(topicUri, endpoint);
}

public V1CamelJmsBindingModelTest() {
    super(JmsEndpoint.class, CAMEL_XML);

    setSkipCamelEndpointTesting(true);
}

public V1CamelAmqpBindingModelTest() {
    super(JmsEndpoint.class, CAMEL_XML);

    setSkipCamelEndpointTesting(true);
}

/**
 * Use a fixed JMS message selector
 *
 * @param endpoint the endpoint
 * @param fixedMessageSelector the fixed selector
 */
public SharedQueueMessageListenerContainer(JmsEndpoint endpoint, String fixedMessageSelector) {
    super(endpoint, endpoint.isAllowReplyManagerQuickStop());
    this.fixedMessageSelector = fixedMessageSelector;
}

/**
 * Use a dynamic JMS message selector
 *
 * @param endpoint the endpoint
 * @param creator the create to create the dynamic selector
 */
public SharedQueueMessageListenerContainer(JmsEndpoint endpoint, MessageSelectorCreator creator) {
    super(endpoint, endpoint.isAllowReplyManagerQuickStop());
    this.creator = creator;
}

/**
 * Sets the belonging {@link org.apache.camel.component.jms.JmsEndpoint}.
 */
void setEndpoint(JmsEndpoint endpoint);