本文整理汇总了Java中org.springframework.jms.listener.adapter.MessageListenerAdapter类的典型用法代码示例。如果您正苦于以下问题：Java MessageListenerAdapter类的具体用法？Java MessageListenerAdapter怎么用？Java MessageListenerAdapter使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
MessageListenerAdapter类属于org.springframework.jms.listener.adapter包，在下文中一共展示了MessageListenerAdapter类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: responder
import org.springframework.jms.listener.adapter.MessageListenerAdapter; //导入依赖的package包/类
@Bean
public DefaultMessageListenerContainer responder() {
DefaultMessageListenerContainer container = new DefaultMessageListenerContainer();
container.setConnectionFactory(connectionFactory());
container.setDestinationName("test.out");
MessageListenerAdapter adapter = new MessageListenerAdapter(new Object() {
@SuppressWarnings("unused")
public String handleMessage(String in) {
return in.toUpperCase();
}
});
container.setMessageListener(adapter);
return container;
}
开发者ID:snicoll，项目名称:scratches，代码行数:17，代码来源:JmsRequestReply.java
示例2: testJcaContainerConfiguration
import org.springframework.jms.listener.adapter.MessageListenerAdapter; //导入依赖的package包/类
@Test
public void testJcaContainerConfiguration() throws Exception {
Map<String, JmsMessageEndpointManager> containers = context.getBeansOfType(JmsMessageEndpointManager.class);
assertTrue("listener3 not found", containers.containsKey("listener3"));
JmsMessageEndpointManager listener3 = containers.get("listener3");
assertEquals("Wrong resource adapter",
context.getBean("testResourceAdapter"), listener3.getResourceAdapter());
assertEquals("Wrong activation spec factory", context.getBean("testActivationSpecFactory"),
new DirectFieldAccessor(listener3).getPropertyValue("activationSpecFactory"));
Object endpointFactory = new DirectFieldAccessor(listener3).getPropertyValue("endpointFactory");
Object messageListener = new DirectFieldAccessor(endpointFactory).getPropertyValue("messageListener");
assertEquals("Wrong message listener", MessageListenerAdapter.class, messageListener.getClass());
MessageListenerAdapter adapter = (MessageListenerAdapter) messageListener;
DirectFieldAccessor adapterFieldAccessor = new DirectFieldAccessor(adapter);
assertEquals("Message converter not set properly", context.getBean("testMessageConverter"),
adapterFieldAccessor.getPropertyValue("messageConverter"));
assertEquals("Wrong delegate", context.getBean("testBean1"),
adapterFieldAccessor.getPropertyValue("delegate"));
assertEquals("Wrong method name", "setName",
adapterFieldAccessor.getPropertyValue("defaultListenerMethod"));
}
开发者ID:langtianya，项目名称:spring4-understanding，代码行数:25，代码来源:JmsNamespaceHandlerTests.java
示例3: setupJmsMessageContainerFullConfig
import org.springframework.jms.listener.adapter.MessageListenerAdapter; //导入依赖的package包/类
@Test
public void setupJmsMessageContainerFullConfig() {
DefaultMessageListenerContainer container = new DefaultMessageListenerContainer();
MessageListener messageListener = new MessageListenerAdapter();
SimpleJmsListenerEndpoint endpoint = new SimpleJmsListenerEndpoint();
endpoint.setDestination("myQueue");
endpoint.setSelector("foo = 'bar'");
endpoint.setSubscription("mySubscription");
endpoint.setConcurrency("5-10");
endpoint.setMessageListener(messageListener);
endpoint.setupListenerContainer(container);
assertEquals("myQueue", container.getDestinationName());
assertEquals("foo = 'bar'", container.getMessageSelector());
assertEquals("mySubscription", container.getSubscriptionName());
assertEquals(5, container.getConcurrentConsumers());
assertEquals(10, container.getMaxConcurrentConsumers());
assertEquals(messageListener, container.getMessageListener());
}
开发者ID:langtianya，项目名称:spring4-understanding，代码行数:20，代码来源:JmsListenerEndpointTests.java
示例4: setupMessageContainerUnsupportedContainer
import org.springframework.jms.listener.adapter.MessageListenerAdapter; //导入依赖的package包/类
@Test
public void setupMessageContainerUnsupportedContainer() {
MessageListenerContainer container = mock(MessageListenerContainer.class);
SimpleJmsListenerEndpoint endpoint = new SimpleJmsListenerEndpoint();
endpoint.setMessageListener(new MessageListenerAdapter());
thrown.expect(IllegalArgumentException.class);
endpoint.setupListenerContainer(container);
}
开发者ID:langtianya，项目名称:spring4-understanding，代码行数:10，代码来源:JmsListenerEndpointTests.java
示例5: createSimpleContainer
import org.springframework.jms.listener.adapter.MessageListenerAdapter; //导入依赖的package包/类
@Test
public void createSimpleContainer() {
SimpleJmsListenerContainerFactory factory = new SimpleJmsListenerContainerFactory();
setDefaultJmsConfig(factory);
SimpleJmsListenerEndpoint endpoint = new SimpleJmsListenerEndpoint();
MessageListener messageListener = new MessageListenerAdapter();
endpoint.setMessageListener(messageListener);
endpoint.setDestination("myQueue");
SimpleMessageListenerContainer container = factory.createListenerContainer(endpoint);
assertDefaultJmsConfig(container);
assertEquals(messageListener, container.getMessageListener());
assertEquals("myQueue", container.getDestinationName());
}
开发者ID:langtianya，项目名称:spring4-understanding，代码行数:17，代码来源:JmsListenerContainerFactoryTests.java
示例6: createJmsContainerFullConfig
import org.springframework.jms.listener.adapter.MessageListenerAdapter; //导入依赖的package包/类
@Test
public void createJmsContainerFullConfig() {
DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
setDefaultJmsConfig(factory);
factory.setCacheLevel(DefaultMessageListenerContainer.CACHE_CONSUMER);
factory.setConcurrency("3-10");
factory.setMaxMessagesPerTask(5);
SimpleJmsListenerEndpoint endpoint = new SimpleJmsListenerEndpoint();
MessageListener messageListener = new MessageListenerAdapter();
endpoint.setMessageListener(messageListener);
endpoint.setDestination("myQueue");
DefaultMessageListenerContainer container = factory.createListenerContainer(endpoint);
assertDefaultJmsConfig(container);
assertEquals(DefaultMessageListenerContainer.CACHE_CONSUMER, container.getCacheLevel());
assertEquals(3, container.getConcurrentConsumers());
assertEquals(10, container.getMaxConcurrentConsumers());
assertEquals(5, container.getMaxMessagesPerTask());
assertEquals(messageListener, container.getMessageListener());
assertEquals("myQueue", container.getDestinationName());
}
开发者ID:langtianya，项目名称:spring4-understanding，代码行数:24，代码来源:JmsListenerContainerFactoryTests.java
示例7: createJcaContainerFullConfig
import org.springframework.jms.listener.adapter.MessageListenerAdapter; //导入依赖的package包/类
@Test
public void createJcaContainerFullConfig() {
DefaultJcaListenerContainerFactory factory = new DefaultJcaListenerContainerFactory();
setDefaultJcaConfig(factory);
factory.setConcurrency("10");
SimpleJmsListenerEndpoint endpoint = new SimpleJmsListenerEndpoint();
MessageListener messageListener = new MessageListenerAdapter();
endpoint.setMessageListener(messageListener);
endpoint.setDestination("myQueue");
JmsMessageEndpointManager container = factory.createListenerContainer(endpoint);
assertDefaultJcaConfig(container);
assertEquals(10, container.getActivationSpecConfig().getMaxConcurrency());
assertEquals(messageListener, container.getMessageListener());
assertEquals("myQueue", container.getActivationSpecConfig().getDestinationName());
}
开发者ID:langtianya，项目名称:spring4-understanding，代码行数:18，代码来源:JmsListenerContainerFactoryTests.java
示例8: registerListenerEndpoint
import org.springframework.jms.listener.adapter.MessageListenerAdapter; //导入依赖的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
示例9: startListener
import org.springframework.jms.listener.adapter.MessageListenerAdapter; //导入依赖的package包/类
public void startListener() {
MessageListenerAdapter messageListenerAdapter = new MessageListenerAdapter();
messageListenerAdapter.setDelegate(this);
messageListenerAdapter.setMessageConverter(mqMessageConverter);
DefaultMessageListenerContainer mqListener = new DefaultMessageListenerContainer();
mqListener.setConnectionFactory(mqConnectionFactory.getFactory());
mqListener.setDestinationName(appConfig.getMqQueueName());
mqListener.setMessageListener(messageListenerAdapter);
mqListener.setConcurrency("4-8");
mqListener.setSessionTransacted(true);
mqListener.initialize();
mqListener.start();
}
开发者ID:phpdragon，项目名称:JavaSamples，代码行数:16，代码来源:MqConsumer.java
示例10: setupJcaMessageContainerFullConfig
import org.springframework.jms.listener.adapter.MessageListenerAdapter; //导入依赖的package包/类
@Test
public void setupJcaMessageContainerFullConfig() {
JmsMessageEndpointManager container = new JmsMessageEndpointManager();
MessageListener messageListener = new MessageListenerAdapter();
SimpleJmsListenerEndpoint endpoint = new SimpleJmsListenerEndpoint();
endpoint.setDestination("myQueue");
endpoint.setSelector("foo = 'bar'");
endpoint.setSubscription("mySubscription");
endpoint.setConcurrency("10");
endpoint.setMessageListener(messageListener);
endpoint.setupListenerContainer(container);
JmsActivationSpecConfig config = container.getActivationSpecConfig();
assertEquals("myQueue", config.getDestinationName());
assertEquals("foo = 'bar'", config.getMessageSelector());
assertEquals("mySubscription", config.getSubscriptionName());
assertEquals(10, config.getMaxConcurrency());
assertEquals(messageListener, container.getMessageListener());
}
开发者ID:langtianya，项目名称:spring4-understanding，代码行数:20，代码来源:JmsListenerEndpointTests.java
示例11: createListener
import org.springframework.jms.listener.adapter.MessageListenerAdapter; //导入依赖的package包/类
@Test
public void createListener() {
SimpleJmsListenerEndpoint endpoint = new SimpleJmsListenerEndpoint();
MessageListener messageListener = new MessageListenerAdapter();
endpoint.setMessageListener(messageListener);
assertSame(messageListener, endpoint.createMessageListener(container));
}
开发者ID:langtianya，项目名称:spring4-understanding，代码行数:8，代码来源:SimpleJmsListenerEndpointTests.java
示例12: jcaExclusiveProperties
import org.springframework.jms.listener.adapter.MessageListenerAdapter; //导入依赖的package包/类
@Test
public void jcaExclusiveProperties() {
DefaultJcaListenerContainerFactory factory = new DefaultJcaListenerContainerFactory();
factory.setDestinationResolver(destinationResolver);
factory.setActivationSpecFactory(new StubJmsActivationSpecFactory());
SimpleJmsListenerEndpoint endpoint = new SimpleJmsListenerEndpoint();
endpoint.setMessageListener(new MessageListenerAdapter());
thrown.expect(IllegalStateException.class);
factory.createListenerContainer(endpoint);
}
开发者ID:langtianya，项目名称:spring4-understanding，代码行数:12，代码来源:JmsListenerContainerFactoryTests.java
示例13: backOffOverridesRecoveryInterval
import org.springframework.jms.listener.adapter.MessageListenerAdapter; //导入依赖的package包/类
@Test
public void backOffOverridesRecoveryInterval() {
DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
BackOff backOff = new FixedBackOff();
factory.setBackOff(backOff);
factory.setRecoveryInterval(2000L);
SimpleJmsListenerEndpoint endpoint = new SimpleJmsListenerEndpoint();
MessageListener messageListener = new MessageListenerAdapter();
endpoint.setMessageListener(messageListener);
endpoint.setDestination("myQueue");
DefaultMessageListenerContainer container = factory.createListenerContainer(endpoint);
assertSame(backOff, new DirectFieldAccessor(container).getPropertyValue("backOff"));
}
开发者ID:langtianya，项目名称:spring4-understanding，代码行数:16，代码来源:JmsListenerContainerFactoryTests.java
示例14: adapter
import org.springframework.jms.listener.adapter.MessageListenerAdapter; //导入依赖的package包/类
@Bean
public MessageListenerAdapter adapter(AuditLogger auditLogger) {
MessageListenerAdapter messageListener
= new MessageListenerAdapter(auditLogger);
messageListener.setDefaultListenerMethod("log");
return messageListener;
}
开发者ID:davyvanroy，项目名称:jpa-audit-jms，代码行数:8，代码来源:JmsConfig.java
示例15: adapter
import org.springframework.jms.listener.adapter.MessageListenerAdapter; //导入依赖的package包/类
/**
* Message listener adapter to listen on new messages
*
* @param receiver
* @return MessageListenerAdapter
*/
@Bean
MessageListenerAdapter adapter(final Receiver receiver) {
MessageListenerAdapter messageListener = new MessageListenerAdapter(receiver);
messageListener.setDefaultListenerMethod("receiveMessage");
return messageListener;
}
开发者ID:t1m0，项目名称:Spring-Examples，代码行数:13，代码来源:AppConfig.java
示例16: adapter
import org.springframework.jms.listener.adapter.MessageListenerAdapter; //导入依赖的package包/类
@Bean
MessageListenerAdapter adapter(JMSReceiver receiver) {
MessageListenerAdapter messageListener = new MessageListenerAdapter(receiver);
messageListener.setDefaultListenerMethod("receiveMessage");
return messageListener;
}
开发者ID:huangye177，项目名称:spring4probe，代码行数:8，代码来源:JMSConfig.java
示例17: deleteContainer
import org.springframework.jms.listener.adapter.MessageListenerAdapter; //导入依赖的package包/类
@Bean
DefaultMessageListenerContainer deleteContainer(MessageListenerAdapter deleteListenerAdapter,
ConnectionFactory connectionFactory) {
DefaultMessageListenerContainer container = new DefaultMessageListenerContainer();
container.setMessageListener(deleteListenerAdapter);
container.setConnectionFactory(connectionFactory);
container.setDestinationName(deleteDocumentsQueueName);
return container;
}
开发者ID:nationalarchives，项目名称:taxonomy，代码行数:10，代码来源:DeleteMsgConfiguration.java
示例18: categorisationContainer
import org.springframework.jms.listener.adapter.MessageListenerAdapter; //导入依赖的package包/类
@Bean
DefaultMessageListenerContainer categorisationContainer(MessageListenerAdapter categorisationListenerAdapter,
ConnectionFactory connectionFactory) {
DefaultMessageListenerContainer container = new DefaultMessageListenerContainer();
container.setMessageListener(categorisationListenerAdapter);
container.setConnectionFactory(connectionFactory);
container.setDestinationName(categoriseDocumentsQueueName);
return container;
}
开发者ID:nationalarchives，项目名称:taxonomy，代码行数:10，代码来源:CategorisationMsgConfiguration.java
示例19: simpleMessageListener
import org.springframework.jms.listener.adapter.MessageListenerAdapter; //导入依赖的package包/类
@Bean
public MessageListener simpleMessageListener() {
return new MessageListenerAdapter();
}
开发者ID:langtianya，项目名称:spring4-understanding，代码行数:5，代码来源:EnableJmsTests.java
示例20: createDummyEndpoint
import org.springframework.jms.listener.adapter.MessageListenerAdapter; //导入依赖的package包/类
private JmsListenerEndpoint createDummyEndpoint() {
SimpleJmsListenerEndpoint endpoint = new SimpleJmsListenerEndpoint();
endpoint.setMessageListener(new MessageListenerAdapter());
endpoint.setDestination("testQueue");
return endpoint;
}
开发者ID:langtianya，项目名称:spring4-understanding，代码行数:7，代码来源:JmsNamespaceHandlerTests.java
注：本文中的org.springframework.jms.listener.adapter.MessageListenerAdapter类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论