|
ActiveMQ example source code file (InvokeMessageListenerTest.java)
The ActiveMQ InvokeMessageListenerTest.java source code/** * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package org.apache.activemq.camel.converter; import java.util.List; import javax.jms.Message; import javax.jms.TextMessage; import static org.apache.activemq.camel.component.ActiveMQComponent.activeMQComponent; import org.apache.activemq.spring.ConsumerBean; import org.apache.camel.CamelContext; import org.apache.camel.ContextTestSupport; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.component.mock.MockEndpoint; /** * */ public class InvokeMessageListenerTest extends ContextTestSupport { protected MockEndpoint resultEndpoint; protected String startEndpointUri = "activemq:queue:test.a"; protected ConsumerBean listener = new ConsumerBean(); public void testSendTextMessage() throws Exception { String expectedBody = "Hello there!"; template.sendBodyAndHeader(startEndpointUri, expectedBody, "cheese", 123); listener.assertMessagesArrived(1); List<Message> list = listener.flushMessages(); assertTrue("Should have received some messages!", !list.isEmpty()); Message message = list.get(0); log.debug("Received: " + message); TextMessage textMessage = assertIsInstanceOf(TextMessage.class, message); assertEquals("Text mesage body: " + textMessage, expectedBody, textMessage.getText()); } protected CamelContext createCamelContext() throws Exception { CamelContext camelContext = super.createCamelContext(); camelContext.addComponent("activemq", activeMQComponent("vm://localhost?broker.persistent=false")); return camelContext; } protected RouteBuilder createRouteBuilder() throws Exception { return new RouteBuilder() { public void configure() throws Exception { from(startEndpointUri).bean(listener); } }; } } Other ActiveMQ examples (source code examples)Here is a short list of links related to this ActiveMQ InvokeMessageListenerTest.java source code file: |
... this post is sponsored by my books ... | |
#1 New Release! |
FP Best Seller |
Copyright 1998-2021 Alvin Alexander, alvinalexander.com
All Rights Reserved.
A percentage of advertising revenue from
pages under the /java/jwarehouse
URI on this website is
paid back to open source projects.