本文整理汇总了Java中org.springframework.jms.config.SimpleJmsListenerEndpoint类的典型用法代码示例。如果您正苦于以下问题:Java SimpleJmsListenerEndpoint类的具体用法?Java SimpleJmsListenerEndpoint怎么用?Java SimpleJmsListenerEndpoint使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
SimpleJmsListenerEndpoint类属于org.springframework.jms.config包,在下文中一共展示了SimpleJmsListenerEndpoint类的8个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: testCustomConfiguration
import org.springframework.jms.config.SimpleJmsListenerEndpoint; //导入依赖的package包/类
/**
* Test for {@link CustomBean} and an manually endpoint registered
* with "myCustomEndpointId". The custom endpoint does not provide
* any factory so it's registered with the default one
*/
public void testCustomConfiguration(ApplicationContext context) {
JmsListenerContainerTestFactory defaultFactory =
context.getBean("jmsListenerContainerFactory", JmsListenerContainerTestFactory.class);
JmsListenerContainerTestFactory customFactory =
context.getBean("customFactory", JmsListenerContainerTestFactory.class);
assertEquals(1, defaultFactory.getListenerContainers().size());
assertEquals(1, customFactory.getListenerContainers().size());
JmsListenerEndpoint endpoint = defaultFactory.getListenerContainers().get(0).getEndpoint();
assertEquals("Wrong endpoint type", SimpleJmsListenerEndpoint.class, endpoint.getClass());
assertEquals("Wrong listener set in custom endpoint", context.getBean("simpleMessageListener"),
((SimpleJmsListenerEndpoint) endpoint).getMessageListener());
JmsListenerEndpointRegistry customRegistry =
context.getBean("customRegistry", JmsListenerEndpointRegistry.class);
assertEquals("Wrong number of containers in the registry", 2,
customRegistry.getListenerContainerIds().size());
assertEquals("Wrong number of containers in the registry", 2,
customRegistry.getListenerContainers().size());
assertNotNull("Container with custom id on the annotation should be found",
customRegistry.getListenerContainer("listenerId"));
assertNotNull("Container created with custom id should be found",
customRegistry.getListenerContainer("myCustomEndpointId"));
}
开发者ID:langtianya,项目名称:spring4-understanding,代码行数:29,代码来源:AbstractJmsAnnotationDrivenTests.java
示例2: registerListenerEndpoint
import org.springframework.jms.config.SimpleJmsListenerEndpoint; //导入依赖的package包/类
private void registerListenerEndpoint(JmsListenerEndpointRegistrar aRegistrar, String aQueueName, int aConcurrency, Object aDelegate, String aMethodName) {
logger.info("Registring JMS Listener: {} -> {}:{}", aQueueName, aDelegate.getClass().getName(), aMethodName);
MessageListenerAdapter messageListener = new MessageListenerAdapter(aDelegate);
messageListener.setMessageConverter(jacksonJmsMessageConverter(objectMapper));
messageListener.setDefaultListenerMethod(aMethodName);
SimpleJmsListenerEndpoint endpoint = new SimpleJmsListenerEndpoint();
endpoint.setId(aQueueName+"Endpoint");
endpoint.setDestination(aQueueName);
endpoint.setMessageListener(messageListener);
aRegistrar.registerEndpoint(endpoint,createContainerFactory(aConcurrency));
}
开发者ID:creactiviti,项目名称:piper,代码行数:15,代码来源:JmsMessengerConfiguration.java
示例3: testSpringReceiverXa
import org.springframework.jms.config.SimpleJmsListenerEndpoint; //导入依赖的package包/类
@Test
public void testSpringReceiverXa() throws Exception {
ConnectionFactory cf = createCF(BROKER_URL);
DefaultJmsListenerContainerFactory jlcf = new DefaultJmsListenerContainerFactory();
jlcf.setTransactionManager(ptm);
jlcf.setSessionTransacted(true);
jlcf.setConnectionFactory(cf);
AtomicReference<Message> holder = new AtomicReference<>();
SimpleJmsListenerEndpoint jle = new SimpleJmsListenerEndpoint();
jle.setDestination(QUEUE);
jle.setMessageListener(message -> {
synchronized (holder) {
holder.set(message);
holder.notifyAll();
}
});
DefaultMessageListenerContainer mlc = jlcf.createListenerContainer(jle);
mlc.initialize();
mlc.start();
JmsTemplate jms = new JmsTemplate(cf);
jms.setDefaultDestinationName(QUEUE);
synchronized (holder) {
jms.convertAndSend("Hello");
holder.wait();
}
assertNotNull(holder.get());
}
开发者ID:ops4j,项目名称:org.ops4j.pax.transx,代码行数:34,代码来源:ActiveMQTest.java
示例4: configureJmsListeners
import org.springframework.jms.config.SimpleJmsListenerEndpoint; //导入依赖的package包/类
@Override
public void configureJmsListeners(JmsListenerEndpointRegistrar registrar) {
registrar.setEndpointRegistry(customRegistry());
// Also register a custom endpoint
SimpleJmsListenerEndpoint endpoint = new SimpleJmsListenerEndpoint();
endpoint.setId("myCustomEndpointId");
endpoint.setDestination("myQueue");
endpoint.setMessageListener(simpleMessageListener());
registrar.registerEndpoint(endpoint);
}
开发者ID:langtianya,项目名称:spring4-understanding,代码行数:12,代码来源:EnableJmsTests.java
示例5: configureJmsListeners
import org.springframework.jms.config.SimpleJmsListenerEndpoint; //导入依赖的package包/类
@Override
public void configureJmsListeners(JmsListenerEndpointRegistrar registrar) {
SimpleJmsListenerEndpoint endpoint = new SimpleJmsListenerEndpoint();
endpoint.setId("myCustomEndpointId");
endpoint.setDestination("myQueue");
endpoint.setMessageListener(messageListener);
registrar.registerEndpoint(endpoint);
}
开发者ID:langtianya,项目名称:spring4-understanding,代码行数:9,代码来源:AnnotationDrivenNamespaceTests.java
示例6: configureJmsListeners
import org.springframework.jms.config.SimpleJmsListenerEndpoint; //导入依赖的package包/类
@Override
public void configureJmsListeners(JmsListenerEndpointRegistrar registrar) {
SimpleJmsListenerEndpoint endpoint = new SimpleJmsListenerEndpoint();
endpoint.setId("myJmsEndpoint");
endpoint.setDestination(environment.getProperty("queue", "test.queue"));
endpoint.setMessageListener(message -> {
try {
System.out.print(((TextMessage)message).getText());
} catch (JMSException e) {
e.printStackTrace();
}
});
registrar.registerEndpoint(endpoint);
}
开发者ID:aquaplanet,项目名称:activemq-demo,代码行数:15,代码来源:ConsumerApplication.java
示例7: configureJmsListeners
import org.springframework.jms.config.SimpleJmsListenerEndpoint; //导入依赖的package包/类
@Override
public void configureJmsListeners(JmsListenerEndpointRegistrar registrar) {
registrar.setContainerFactory(containerFactory);
SimpleJmsListenerEndpoint endpoint = new SimpleJmsListenerEndpoint();
endpoint.setDestination("core-" + this.type + "-actions");
endpoint.setMessageListener(this);
loadProperties();
log.debug("CONFIGURE Properties are: " + properties);
endpoint.setConcurrency("5-" + properties.getProperty("concurrency", "15"));
endpoint.setId(String.valueOf(Thread.currentThread().getId()));
registrar.registerEndpoint(endpoint);
}
开发者ID:openbaton,项目名称:openbaton-libs,代码行数:13,代码来源:AbstractVnfmSpringJMS.java
示例8: configureEndpoint
import org.springframework.jms.config.SimpleJmsListenerEndpoint; //导入依赖的package包/类
/**
* Configure one endpoint
*
* @param endpointId
* @param defaultLogin
* @param defaultPassword
* @return Configured endpoint
*/
private JmsListenerEndpoint configureEndpoint(String endpointId, String defaultLogin, String defaultPassword) throws Exception {
// Define the endpoint
SimpleJmsListenerEndpoint endpoint = new SimpleJmsListenerEndpoint();
endpoint.setId(endpointId);
endpoint.setDestination(getRequiredEndpointProperty(endpointId, CONFIGURATION_KEY_JMS_ENDPOINT_DESTINATION));
String selector = getEndpointProperty(endpointId, CONFIGURATION_KEY_JMS_ENDPOINT_SELECTOR);
if (!StringUtils.isEmpty(selector)) {
endpoint.setSelector(selector);
}
// Define the receiver
//DefltMessageListener receiver = new DefaultMessageListener();
String login = getEndpointProperty(endpointId, CONFIGURATION_KEY_JMS_ENDPOINT_LOGIN, defaultLogin);
String password = getEndpointProperty(endpointId, CONFIGURATION_KEY_JMS_ENDPOINT_PASSWORD, defaultPassword);
String definitionsIdentifier = getRequiredEndpointProperty(endpointId, CONFIGURATION_KEY_JMS_ENDPOINT_BPMN_DEFINITION);
String actionAsString = getEndpointProperty(endpointId, CONFIGURATION_KEY_JMS_ENDPOINT_BPMN_ACTION);
BpmnAction action = BpmnAction.INSTANTIATE;
try {
action = BpmnAction.parse(actionAsString);
} catch (IllegalArgumentException wrongArgument) {
StringBuilder errorMessage = new StringBuilder();
errorMessage.append("Action ('").append(actionAsString).append("') unknown for endpoint '");
errorMessage.append(endpointId).append(" : only 'instantiate' or 'signal' are allowed.");
if (ignoreErroneousEndpoint) {
errorMessage.append(" Instantiate will be used.");
logger.warn(errorMessage.toString());
}
else {
throw new IllegalArgumentException(errorMessage.toString());
}
}
Map<String, ? extends Object> listenerProperties = subsetToCamelCase(configuration, getEndpointBpmnPropertiesPrefix(endpointId), true);
AbstractW4MessageListener listener = listenerFactory.getListener(action, login, password, definitionsIdentifier, listenerProperties);
// Define the listener
//MessageListenerAdapter listener = new MessageListenerAdapter(receiver);
MessagingMessageListenerAdapter listenerAdapter = new DisposableMessagingMessageListenerAdapter();
listenerAdapter.setHandlerMethod(methodFactory.createInvocableHandlerMethod(listener, getHandleMethod()));
// Set the mapping if needed
setMapping(endpointId, listenerAdapter);
endpoint.setMessageListener(listenerAdapter);
return endpoint;
}
开发者ID:benjamin-cartereau,项目名称:w4-bpmnplus-module-jms,代码行数:59,代码来源:ApplicationConfig.java
注:本文中的org.springframework.jms.config.SimpleJmsListenerEndpoint类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论