You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@camel.apache.org by deb02anjan <de...@gmail.com> on 2015/08/08 23:48:30 UTC
Error when trying to send file contents to ActiveMq
Hi,
I am very new to the world of spring, camel and activemq.
I am trying to write a code using camel that will poll a file directory and
send the contents of the files inside it to a activemq queue. I need it to
be configured using spring.
The code is given below along with the log. Please help. Thanks in advance.
pom.xml
--------
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.learn.camel</groupId>
<artifactId>CamelDemo</artifactId>
<version>0.0.1-SNAPSHOT</version>
<dependencies>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-core</artifactId>
<version>2.15.2</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jms</artifactId>
<version>3.1.0.RELEASE</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-jms</artifactId>
<version>2.15.2</version>
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-spring</artifactId>
<version>2.15.2</version>
</dependency>
<dependency>
<groupId>org.apache.xbean</groupId>
<artifactId>xbean-spring</artifactId>
<version>4.3</version>
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-aws</artifactId>
<version>2.15.2</version>
</dependency>
<dependency>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-all</artifactId>
<version>5.1.0</version>
<scope>compile</scope>
</dependency>
</dependencies>
</project>
CamelHello.java
----------------
package com.learn.camel.filetoqueue;
import org.apache.camel.CamelContext;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.FileSystemXmlApplicationContext;
public class CamelHello {
public static void main(String args[]) throws Exception {
try {
ApplicationContext springcontext = new
FileSystemXmlApplicationContext("src/main/resources/QBeans.xml");
CamelContext context = springcontext.getBean("camel",
CamelContext.class);
context.start();
context.stop();
} catch ( Exception e ) {
}
}
}
QBeans.xml
----------
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-4.2.xsd
http://activemq.apache.org/schema/core
http://activemq.apache.org/schema/core/activemq-core-5.11.1.xsd
http://camel.apache.org/schema/spring
http://camel.apache.org/schema/spring/camel-spring-2.15.2.xsd">
<camelContext id="camel" xmlns="http://camel.apache.org/schema/spring">
<route>
<from uri="file:C:/Users/abcd/Desktop/targetconsumer.delay=1000" />
<convertBodyTo type="java.lang.String" />
<to uri="activemq:queue:SAMPLEQUEUE" />
</route>
</camelContext>
<bean id="activemq"
class="org.apache.activemq.camel.component.ActiveMQComponent">
<property name="brokerURL" value="tcp://0.0.0.0:61616" />
</bean>
<broker:broker useJmx="true" persistent="false"
xmlns:broker="http://activemq.apache.org/schema/core" >
<broker:transportConnectors>
<broker:transportConnector uri="tcp://0.0.0.0:61616" />
</broker:transportConnectors>
</broker:broker>
</beans>
Aug 09, 2015 2:26:28 AM
org.springframework.context.support.AbstractApplicationContext
prepareRefresh
INFO: Refreshing
org.springframework.context.support.FileSystemXmlApplicationContext@31221be2:
startup date [Sun Aug 09 02:26:28 IST 2015]; root of context hierarchy
Aug 09, 2015 2:26:28 AM
org.springframework.beans.factory.xml.XmlBeanDefinitionReader
loadBeanDefinitions
INFO: Loading XML bean definitions from file
[C:\workspace\CamelDemo\src\main\resources\QBeans.xml]
SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further
details.
Aug 09, 2015 2:26:30 AM
org.springframework.beans.factory.support.DefaultListableBeanFactory
preInstantiateSingletons
INFO: Pre-instantiating singletons in
org.springframework.beans.factory.support.DefaultListableBeanFactory@76b1e9b8:
defining beans
[template,consumerTemplate,camel:beanPostProcessor,camel,activemq,org.apache.activemq.xbean.XBeanBrokerService#0];
root of factory hierarchy
Aug 09, 2015 2:26:30 AM org.apache.activemq.broker.BrokerService start
INFO: Using Persistence Adapter: MemoryPersistenceAdapter
Aug 09, 2015 2:26:30 AM org.apache.activemq.broker.BrokerService getBroker
INFO: ActiveMQ null JMS Message Broker (localhost) is starting
Aug 09, 2015 2:26:30 AM org.apache.activemq.broker.BrokerService getBroker
INFO: For help or more information please see: http://activemq.apache.org/
Aug 09, 2015 2:26:31 AM org.apache.activemq.broker.jmx.ManagementContext$1
run
INFO: JMX consoles can connect to
service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi
Aug 09, 2015 2:26:31 AM org.apache.activemq.broker.BrokerService start
SEVERE: Failed to start ActiveMQ JMS Message Broker. Reason:
java.io.IOException: Transport Connector could not be registered in JMX:
Failed to bind to server socket: tcp://0.0.0.0:61616 due to:
java.net.BindException: Address already in use: JVM_Bind
java.io.IOException: Transport Connector could not be registered in JMX:
Failed to bind to server socket: tcp://0.0.0.0:61616 due to:
java.net.BindException: Address already in use: JVM_Bind
at
org.apache.activemq.util.IOExceptionSupport.create(IOExceptionSupport.java:27)
at
org.apache.activemq.broker.BrokerService.registerConnectorMBean(BrokerService.java:1395)
at
org.apache.activemq.broker.BrokerService.startTransportConnector(BrokerService.java:1848)
at
org.apache.activemq.broker.BrokerService.startAllConnectors(BrokerService.java:1801)
at org.apache.activemq.broker.BrokerService.start(BrokerService.java:455)
at
org.apache.activemq.xbean.XBeanBrokerService.afterPropertiesSet(XBeanBrokerService.java:50)
at
org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeInitMethods(AbstractAutowireCapableBeanFactory.java:1514)
at
org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1452)
at
org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:519)
at
org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:456)
at
org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:294)
at
org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:225)
at
org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:291)
at
org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:193)
at
org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:585)
at
org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:913)
at
org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:464)
at
org.springframework.context.support.FileSystemXmlApplicationContext.<init>(FileSystemXmlApplicationContext.java:140)
at
org.springframework.context.support.FileSystemXmlApplicationContext.<init>(FileSystemXmlApplicationContext.java:84)
at com.learn.camel.filetoqueue.CamelHello.main(CamelHello.java:11)
Caused by: java.io.IOException: Failed to bind to server socket:
tcp://0.0.0.0:61616 due to: java.net.BindException: Address already in use:
JVM_Bind
at
org.apache.activemq.util.IOExceptionSupport.create(IOExceptionSupport.java:33)
at
org.apache.activemq.transport.tcp.TcpTransportServer.bind(TcpTransportServer.java:124)
at
org.apache.activemq.transport.tcp.TcpTransportFactory.doBind(TcpTransportFactory.java:60)
at
org.apache.activemq.transport.TransportFactory.bind(TransportFactory.java:123)
at
org.apache.activemq.broker.TransportConnector.createTransportServer(TransportConnector.java:293)
at
org.apache.activemq.broker.TransportConnector.getServer(TransportConnector.java:135)
at
org.apache.activemq.broker.TransportConnector.asManagedConnector(TransportConnector.java:98)
at
org.apache.activemq.broker.BrokerService.registerConnectorMBean(BrokerService.java:1389)
... 18 more
Caused by: java.net.BindException: Address already in use: JVM_Bind
at java.net.DualStackPlainSocketImpl.bind0(Native Method)
at
java.net.DualStackPlainSocketImpl.socketBind(DualStackPlainSocketImpl.java:106)
at java.net.AbstractPlainSocketImpl.bind(AbstractPlainSocketImpl.java:382)
at java.net.PlainSocketImpl.bind(PlainSocketImpl.java:190)
at java.net.ServerSocket.bind(ServerSocket.java:375)
at java.net.ServerSocket.<init>(ServerSocket.java:237)
at
javax.net.DefaultServerSocketFactory.createServerSocket(ServerSocketFactory.java:231)
at
org.apache.activemq.transport.tcp.TcpTransportServer.bind(TcpTransportServer.java:120)
... 24 more
Aug 09, 2015 2:26:31 AM
org.springframework.beans.factory.support.DefaultSingletonBeanRegistry
destroySingletons
INFO: Destroying singletons in
org.springframework.beans.factory.support.DefaultListableBeanFactory@76b1e9b8:
defining beans
[template,consumerTemplate,camel:beanPostProcessor,camel,activemq,org.apache.activemq.xbean.XBeanBrokerService#0];
root of factory hierarchy
org.springframework.beans.factory.BeanCreationException: Error creating bean
with name 'org.apache.activemq.xbean.XBeanBrokerService#0' defined in file
[C:\workspace\CamelDemo\src\main\resources\QBeans.xml]: Invocation of init
method failed; nested exception is java.io.IOException: Transport Connector
could not be registered in JMX: Failed to bind to server socket:
tcp://0.0.0.0:61616 due to: java.net.BindException: Address already in use:
JVM_Bind
at
org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1455)
at
org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:519)
at
org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:456)
at
org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:294)
at
org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:225)
at
org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:291)
at
org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:193)
at
org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:585)
at
org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:913)
at
org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:464)
at
org.springframework.context.support.FileSystemXmlApplicationContext.<init>(FileSystemXmlApplicationContext.java:140)
at
org.springframework.context.support.FileSystemXmlApplicationContext.<init>(FileSystemXmlApplicationContext.java:84)
at com.learn.camel.filetoqueue.CamelHello.main(CamelHello.java:11)
Caused by: java.io.IOException: Transport Connector could not be registered
in JMX: Failed to bind to server socket: tcp://0.0.0.0:61616 due to:
java.net.BindException: Address already in use: JVM_Bind
at
org.apache.activemq.util.IOExceptionSupport.create(IOExceptionSupport.java:27)
at
org.apache.activemq.broker.BrokerService.registerConnectorMBean(BrokerService.java:1395)
at
org.apache.activemq.broker.BrokerService.startTransportConnector(BrokerService.java:1848)
at
org.apache.activemq.broker.BrokerService.startAllConnectors(BrokerService.java:1801)
at org.apache.activemq.broker.BrokerService.start(BrokerService.java:455)
at
org.apache.activemq.xbean.XBeanBrokerService.afterPropertiesSet(XBeanBrokerService.java:50)
at
org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeInitMethods(AbstractAutowireCapableBeanFactory.java:1514)
at
org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1452)
... 12 more
Caused by: java.io.IOException: Failed to bind to server socket:
tcp://0.0.0.0:61616 due to: java.net.BindException: Address already in use:
JVM_Bind
at
org.apache.activemq.util.IOExceptionSupport.create(IOExceptionSupport.java:33)
at
org.apache.activemq.transport.tcp.TcpTransportServer.bind(TcpTransportServer.java:124)
at
org.apache.activemq.transport.tcp.TcpTransportFactory.doBind(TcpTransportFactory.java:60)
at
org.apache.activemq.transport.TransportFactory.bind(TransportFactory.java:123)
at
org.apache.activemq.broker.TransportConnector.createTransportServer(TransportConnector.java:293)
at
org.apache.activemq.broker.TransportConnector.getServer(TransportConnector.java:135)
at
org.apache.activemq.broker.TransportConnector.asManagedConnector(TransportConnector.java:98)
at
org.apache.activemq.broker.BrokerService.registerConnectorMBean(BrokerService.java:1389)
... 18 more
Caused by: java.net.BindException: Address already in use: JVM_Bind
at java.net.DualStackPlainSocketImpl.bind0(Native Method)
at
java.net.DualStackPlainSocketImpl.socketBind(DualStackPlainSocketImpl.java:106)
at java.net.AbstractPlainSocketImpl.bind(AbstractPlainSocketImpl.java:382)
at java.net.PlainSocketImpl.bind(PlainSocketImpl.java:190)
at java.net.ServerSocket.bind(ServerSocket.java:375)
at java.net.ServerSocket.<init>(ServerSocket.java:237)
at
javax.net.DefaultServerSocketFactory.createServerSocket(ServerSocketFactory.java:231)
at
org.apache.activemq.transport.tcp.TcpTransportServer.bind(TcpTransportServer.java:120)
... 24 more
--
View this message in context: http://camel.465427.n5.nabble.com/Error-when-trying-to-send-file-contents-to-ActiveMq-tp5770476.html
Sent from the Camel Development mailing list archive at Nabble.com.
Re: Error when trying to send file contents to ActiveMq
Posted by Claus Ibsen <cl...@gmail.com>.
Hi
Welcome to this world. You should use the @user / user forum for
asking this kind of question.
You can find a bunch of examples at
http://camel.apache.org/examples
And also some more from the source code
https://github.com/apache/camel/tree/master/examples
There is some of those that are spring based you can use as inspiration.
Your code to start the app is a bit wrong as you call start and then
stop right after. You need to keep the spring app running. There is
usually some better ways to do this more automatic and with less code
yourself. But please ask on the @user / user forum instead of this
@dev which is for talking about the actual development of Camel
itself.
On Sat, Aug 8, 2015 at 11:48 PM, deb02anjan <de...@gmail.com> wrote:
> Hi,
> I am very new to the world of spring, camel and activemq.
> I am trying to write a code using camel that will poll a file directory and
> send the contents of the files inside it to a activemq queue. I need it to
> be configured using spring.
> The code is given below along with the log. Please help. Thanks in advance.
>
> pom.xml
> --------
> <project xmlns="http://maven.apache.org/POM/4.0.0"
> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
> xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
> http://maven.apache.org/xsd/maven-4.0.0.xsd">
> <modelVersion>4.0.0</modelVersion>
> <groupId>com.learn.camel</groupId>
> <artifactId>CamelDemo</artifactId>
> <version>0.0.1-SNAPSHOT</version>
> <dependencies>
>
> <dependency>
> <groupId>org.apache.camel</groupId>
> <artifactId>camel-core</artifactId>
> <version>2.15.2</version>
> </dependency>
>
> <dependency>
> <groupId>org.springframework</groupId>
> <artifactId>spring-jms</artifactId>
> <version>3.1.0.RELEASE</version>
> <scope>compile</scope>
> </dependency>
>
> <dependency>
> <groupId>org.apache.camel</groupId>
> <artifactId>camel-jms</artifactId>
> <version>2.15.2</version>
> </dependency>
>
> <dependency>
> <groupId>org.apache.camel</groupId>
> <artifactId>camel-spring</artifactId>
> <version>2.15.2</version>
> </dependency>
>
> <dependency>
> <groupId>org.apache.xbean</groupId>
> <artifactId>xbean-spring</artifactId>
> <version>4.3</version>
> </dependency>
>
>
> <dependency>
> <groupId>org.apache.camel</groupId>
> <artifactId>camel-aws</artifactId>
> <version>2.15.2</version>
> </dependency>
>
> <dependency>
> <groupId>org.apache.activemq</groupId>
> <artifactId>activemq-all</artifactId>
> <version>5.1.0</version>
> <scope>compile</scope>
> </dependency>
>
> </dependencies>
>
> </project>
>
>
>
> CamelHello.java
> ----------------
> package com.learn.camel.filetoqueue;
> import org.apache.camel.CamelContext;
> import org.springframework.context.ApplicationContext;
> import org.springframework.context.support.FileSystemXmlApplicationContext;
> public class CamelHello {
> public static void main(String args[]) throws Exception {
> try {
> ApplicationContext springcontext = new
> FileSystemXmlApplicationContext("src/main/resources/QBeans.xml");
> CamelContext context = springcontext.getBean("camel",
> CamelContext.class);
> context.start();
> context.stop();
> } catch ( Exception e ) {
> }
> }
> }
>
>
>
> QBeans.xml
> ----------
> <beans xmlns="http://www.springframework.org/schema/beans"
> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
> xsi:schemaLocation="
> http://www.springframework.org/schema/beans
> http://www.springframework.org/schema/beans/spring-beans-4.2.xsd
> http://activemq.apache.org/schema/core
> http://activemq.apache.org/schema/core/activemq-core-5.11.1.xsd
> http://camel.apache.org/schema/spring
> http://camel.apache.org/schema/spring/camel-spring-2.15.2.xsd">
>
> <camelContext id="camel" xmlns="http://camel.apache.org/schema/spring">
> <route>
> <from uri="file:C:/Users/abcd/Desktop/targetconsumer.delay=1000" />
> <convertBodyTo type="java.lang.String" />
> <to uri="activemq:queue:SAMPLEQUEUE" />
> </route>
> </camelContext>
> <bean id="activemq"
> class="org.apache.activemq.camel.component.ActiveMQComponent">
> <property name="brokerURL" value="tcp://0.0.0.0:61616" />
> </bean>
> <broker:broker useJmx="true" persistent="false"
> xmlns:broker="http://activemq.apache.org/schema/core" >
> <broker:transportConnectors>
> <broker:transportConnector uri="tcp://0.0.0.0:61616" />
> </broker:transportConnectors>
> </broker:broker>
> </beans>
>
> Aug 09, 2015 2:26:28 AM
> org.springframework.context.support.AbstractApplicationContext
> prepareRefresh
> INFO: Refreshing
> org.springframework.context.support.FileSystemXmlApplicationContext@31221be2:
> startup date [Sun Aug 09 02:26:28 IST 2015]; root of context hierarchy
> Aug 09, 2015 2:26:28 AM
> org.springframework.beans.factory.xml.XmlBeanDefinitionReader
> loadBeanDefinitions
> INFO: Loading XML bean definitions from file
> [C:\workspace\CamelDemo\src\main\resources\QBeans.xml]
> SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
> SLF4J: Defaulting to no-operation (NOP) logger implementation
> SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further
> details.
> Aug 09, 2015 2:26:30 AM
> org.springframework.beans.factory.support.DefaultListableBeanFactory
> preInstantiateSingletons
> INFO: Pre-instantiating singletons in
> org.springframework.beans.factory.support.DefaultListableBeanFactory@76b1e9b8:
> defining beans
> [template,consumerTemplate,camel:beanPostProcessor,camel,activemq,org.apache.activemq.xbean.XBeanBrokerService#0];
> root of factory hierarchy
> Aug 09, 2015 2:26:30 AM org.apache.activemq.broker.BrokerService start
> INFO: Using Persistence Adapter: MemoryPersistenceAdapter
> Aug 09, 2015 2:26:30 AM org.apache.activemq.broker.BrokerService getBroker
> INFO: ActiveMQ null JMS Message Broker (localhost) is starting
> Aug 09, 2015 2:26:30 AM org.apache.activemq.broker.BrokerService getBroker
> INFO: For help or more information please see: http://activemq.apache.org/
> Aug 09, 2015 2:26:31 AM org.apache.activemq.broker.jmx.ManagementContext$1
> run
> INFO: JMX consoles can connect to
> service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi
> Aug 09, 2015 2:26:31 AM org.apache.activemq.broker.BrokerService start
> SEVERE: Failed to start ActiveMQ JMS Message Broker. Reason:
> java.io.IOException: Transport Connector could not be registered in JMX:
> Failed to bind to server socket: tcp://0.0.0.0:61616 due to:
> java.net.BindException: Address already in use: JVM_Bind
> java.io.IOException: Transport Connector could not be registered in JMX:
> Failed to bind to server socket: tcp://0.0.0.0:61616 due to:
> java.net.BindException: Address already in use: JVM_Bind
> at
> org.apache.activemq.util.IOExceptionSupport.create(IOExceptionSupport.java:27)
> at
> org.apache.activemq.broker.BrokerService.registerConnectorMBean(BrokerService.java:1395)
> at
> org.apache.activemq.broker.BrokerService.startTransportConnector(BrokerService.java:1848)
> at
> org.apache.activemq.broker.BrokerService.startAllConnectors(BrokerService.java:1801)
> at org.apache.activemq.broker.BrokerService.start(BrokerService.java:455)
> at
> org.apache.activemq.xbean.XBeanBrokerService.afterPropertiesSet(XBeanBrokerService.java:50)
> at
> org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeInitMethods(AbstractAutowireCapableBeanFactory.java:1514)
> at
> org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1452)
> at
> org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:519)
> at
> org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:456)
> at
> org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:294)
> at
> org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:225)
> at
> org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:291)
> at
> org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:193)
> at
> org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:585)
> at
> org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:913)
> at
> org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:464)
> at
> org.springframework.context.support.FileSystemXmlApplicationContext.<init>(FileSystemXmlApplicationContext.java:140)
> at
> org.springframework.context.support.FileSystemXmlApplicationContext.<init>(FileSystemXmlApplicationContext.java:84)
> at com.learn.camel.filetoqueue.CamelHello.main(CamelHello.java:11)
> Caused by: java.io.IOException: Failed to bind to server socket:
> tcp://0.0.0.0:61616 due to: java.net.BindException: Address already in use:
> JVM_Bind
> at
> org.apache.activemq.util.IOExceptionSupport.create(IOExceptionSupport.java:33)
> at
> org.apache.activemq.transport.tcp.TcpTransportServer.bind(TcpTransportServer.java:124)
> at
> org.apache.activemq.transport.tcp.TcpTransportFactory.doBind(TcpTransportFactory.java:60)
> at
> org.apache.activemq.transport.TransportFactory.bind(TransportFactory.java:123)
> at
> org.apache.activemq.broker.TransportConnector.createTransportServer(TransportConnector.java:293)
> at
> org.apache.activemq.broker.TransportConnector.getServer(TransportConnector.java:135)
> at
> org.apache.activemq.broker.TransportConnector.asManagedConnector(TransportConnector.java:98)
> at
> org.apache.activemq.broker.BrokerService.registerConnectorMBean(BrokerService.java:1389)
> ... 18 more
> Caused by: java.net.BindException: Address already in use: JVM_Bind
> at java.net.DualStackPlainSocketImpl.bind0(Native Method)
> at
> java.net.DualStackPlainSocketImpl.socketBind(DualStackPlainSocketImpl.java:106)
> at java.net.AbstractPlainSocketImpl.bind(AbstractPlainSocketImpl.java:382)
> at java.net.PlainSocketImpl.bind(PlainSocketImpl.java:190)
> at java.net.ServerSocket.bind(ServerSocket.java:375)
> at java.net.ServerSocket.<init>(ServerSocket.java:237)
> at
> javax.net.DefaultServerSocketFactory.createServerSocket(ServerSocketFactory.java:231)
> at
> org.apache.activemq.transport.tcp.TcpTransportServer.bind(TcpTransportServer.java:120)
> ... 24 more
>
> Aug 09, 2015 2:26:31 AM
> org.springframework.beans.factory.support.DefaultSingletonBeanRegistry
> destroySingletons
> INFO: Destroying singletons in
> org.springframework.beans.factory.support.DefaultListableBeanFactory@76b1e9b8:
> defining beans
> [template,consumerTemplate,camel:beanPostProcessor,camel,activemq,org.apache.activemq.xbean.XBeanBrokerService#0];
> root of factory hierarchy
> org.springframework.beans.factory.BeanCreationException: Error creating bean
> with name 'org.apache.activemq.xbean.XBeanBrokerService#0' defined in file
> [C:\workspace\CamelDemo\src\main\resources\QBeans.xml]: Invocation of init
> method failed; nested exception is java.io.IOException: Transport Connector
> could not be registered in JMX: Failed to bind to server socket:
> tcp://0.0.0.0:61616 due to: java.net.BindException: Address already in use:
> JVM_Bind
> at
> org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1455)
> at
> org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:519)
> at
> org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:456)
> at
> org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:294)
> at
> org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:225)
> at
> org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:291)
> at
> org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:193)
> at
> org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:585)
> at
> org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:913)
> at
> org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:464)
> at
> org.springframework.context.support.FileSystemXmlApplicationContext.<init>(FileSystemXmlApplicationContext.java:140)
> at
> org.springframework.context.support.FileSystemXmlApplicationContext.<init>(FileSystemXmlApplicationContext.java:84)
> at com.learn.camel.filetoqueue.CamelHello.main(CamelHello.java:11)
> Caused by: java.io.IOException: Transport Connector could not be registered
> in JMX: Failed to bind to server socket: tcp://0.0.0.0:61616 due to:
> java.net.BindException: Address already in use: JVM_Bind
> at
> org.apache.activemq.util.IOExceptionSupport.create(IOExceptionSupport.java:27)
> at
> org.apache.activemq.broker.BrokerService.registerConnectorMBean(BrokerService.java:1395)
> at
> org.apache.activemq.broker.BrokerService.startTransportConnector(BrokerService.java:1848)
> at
> org.apache.activemq.broker.BrokerService.startAllConnectors(BrokerService.java:1801)
> at org.apache.activemq.broker.BrokerService.start(BrokerService.java:455)
> at
> org.apache.activemq.xbean.XBeanBrokerService.afterPropertiesSet(XBeanBrokerService.java:50)
> at
> org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeInitMethods(AbstractAutowireCapableBeanFactory.java:1514)
> at
> org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1452)
> ... 12 more
> Caused by: java.io.IOException: Failed to bind to server socket:
> tcp://0.0.0.0:61616 due to: java.net.BindException: Address already in use:
> JVM_Bind
> at
> org.apache.activemq.util.IOExceptionSupport.create(IOExceptionSupport.java:33)
> at
> org.apache.activemq.transport.tcp.TcpTransportServer.bind(TcpTransportServer.java:124)
> at
> org.apache.activemq.transport.tcp.TcpTransportFactory.doBind(TcpTransportFactory.java:60)
> at
> org.apache.activemq.transport.TransportFactory.bind(TransportFactory.java:123)
> at
> org.apache.activemq.broker.TransportConnector.createTransportServer(TransportConnector.java:293)
> at
> org.apache.activemq.broker.TransportConnector.getServer(TransportConnector.java:135)
> at
> org.apache.activemq.broker.TransportConnector.asManagedConnector(TransportConnector.java:98)
> at
> org.apache.activemq.broker.BrokerService.registerConnectorMBean(BrokerService.java:1389)
> ... 18 more
> Caused by: java.net.BindException: Address already in use: JVM_Bind
> at java.net.DualStackPlainSocketImpl.bind0(Native Method)
> at
> java.net.DualStackPlainSocketImpl.socketBind(DualStackPlainSocketImpl.java:106)
> at java.net.AbstractPlainSocketImpl.bind(AbstractPlainSocketImpl.java:382)
> at java.net.PlainSocketImpl.bind(PlainSocketImpl.java:190)
> at java.net.ServerSocket.bind(ServerSocket.java:375)
> at java.net.ServerSocket.<init>(ServerSocket.java:237)
> at
> javax.net.DefaultServerSocketFactory.createServerSocket(ServerSocketFactory.java:231)
> at
> org.apache.activemq.transport.tcp.TcpTransportServer.bind(TcpTransportServer.java:120)
> ... 24 more
>
>
>
> --
> View this message in context: http://camel.465427.n5.nabble.com/Error-when-trying-to-send-file-contents-to-ActiveMq-tp5770476.html
> Sent from the Camel Development mailing list archive at Nabble.com.
--
Claus Ibsen
-----------------
http://davsclaus.com @davsclaus
Camel in Action 2nd edition: http://www.manning.com/ibsen2