You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by Rob Davies <ra...@gmail.com> on 2007/01/25 15:19:19 UTC
Re: a new jms broker started by Consumer
Gulp! - a known issue this is fixed in 4.2
cheers,
Rob
On 25 Jan 2007, at 14:16, Tony Qian wrote:
> All,
>
> Sorry for long message. I tried to set up ActiveMQ broker and got
> following error when try to create a connection at consumer side.
>
> ActiveMQConnectionFactory factory = new
> ActiveMQConnectionFactory("tcp://localhost:61616");
> connection = factory.createQueueConnection();
>
> I don't understand why consumer tried to create database. Why did
> it start a JMS broker. Error msg is attached.
>
> Appreciate your help.
> Tony
>
> 17:39:02.697 main org.apache.activemq.broker.jmx.ManagementContext
> createConnector :Failed to create local registry
> java.rmi.server.ExportException: Port already in use: 1099; nested
> exception is:
> java.net.BindException: Address already in use
> at sun.rmi.transport.tcp.TCPTransport.listen
> (TCPTransport.java:243)
> at sun.rmi.transport.tcp.TCPTransport.exportObject
> (TCPTransport.java:178)
> at sun.rmi.transport.tcp.TCPEndpoint.exportObject
> (TCPEndpoint.java:382)
> at sun.rmi.transport.LiveRef.exportObject(LiveRef.java:116)
> at sun.rmi.server.UnicastServerRef.exportObject
> (UnicastServerRef.java:145)
> at sun.rmi.registry.RegistryImpl.setup(RegistryImpl.java:92)
> at sun.rmi.registry.RegistryImpl.<init>(RegistryImpl.java:78)
> at java.rmi.registry.LocateRegistry.createRegistry
> (LocateRegistry.java:164)
> at
> org.apache.activemq.broker.jmx.ManagementContext.createConnector
> (ManagementContext.java:382)
> at
> org.apache.activemq.broker.jmx.ManagementContext.createMBeanServer
> (ManagementContext.java:367)
> at
> org.apache.activemq.broker.jmx.ManagementContext.findMBeanServer
> (ManagementContext.java:297)
> at
> org.apache.activemq.broker.jmx.ManagementContext.getMBeanServer
> (ManagementContext.java:154)
> at org.apache.activemq.broker.jmx.ManagementContext.start
> (ManagementContext.java:78)
> at org.apache.activemq.broker.BrokerService.start
> (BrokerService.java:391)
> at
> org.apache.activemq.transport.vm.VMTransportFactory.doCompositeConnect
> (VMTransportFactory.java:113)
> at
> org.apache.activemq.transport.vm.VMTransportFactory.doConnect
> (VMTransportFactory.java:52)
> at org.apache.activemq.transport.TransportFactory.doConnect
> (TransportFactory.java:43)
> at org.apache.activemq.transport.TransportFactory.connect
> (TransportFactory.java:77)
> at
> org.apache.activemq.ActiveMQConnectionFactory.createTransport
> (ActiveMQConnectionFactory.java:227)
> at
> org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection
> (ActiveMQConnectionFactory.java:242)
> at
> org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection
> (ActiveMQConnectionFactory.java:211)
> at
> org.apache.activemq.ActiveMQConnectionFactory.createQueueConnection
> (ActiveMQConnectionFactory.java:173)
> at .jms.JMSConnection.connect(Unknown Source)
> at jms.JMSConnection.<init>(Unknown Source)
> at .jms.JMSConnection.<clinit>(Unknown Source)
> at jms.JMSReceiver.<init>(Unknown Source)
> at jms.JMSReceiver.<init>(Unknown Source)
> at .PhoneHomeQueueListener.<init>(Unknown Source)
> ....
>
> 17:39:03.031 main org.apache.activemq.broker.BrokerService
> getBroker :ActiveMQ 4.1.0-incubator JMS Message Broker (localhost)
> is starting
> 17:39:03.032 main org.apache.activemq.broker.BrokerService
> getBroker :For help or more information please see: http://
> incubator.apache.org/activemq/
> 17:39:03.376 JMX connector
> org.apache.activemq.broker.jmx.ManagementContext$1 run :Failed to
> start jmx connector: javax.naming.NameAlreadyBoundException: jmxrmi
> [Root exception is java.rmi.AlreadyBoundException: jmxrmi]
> 17:39:07.309 main
> org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
> createAdapter :Database driver recognized:
> [apache_derby_embedded_jdbc_driver]
> 17:39:09.706 main
> org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
> doCreateTables :Executing SQL: CREATE TABLE ACTIVEMQ_MSGS(ID
> INTEGER NOT NULL, CONTAINER VARCHAR(250), MSGID_PROD VARCHAR(250),
> MSGID_SEQ INTEGER, EXPIRATION BIGINT, MSG BLOB, PRIMARY KEY ( ID ) )
> 17:39:10.214 main
> org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
> doCreateTables :Could not create JDBC tables; The message table
> already existed. Failure was: CREATE TABLE ACTIVEMQ_MSGS(ID INTEGER
> NOT NULL, CONTAINER VARCHAR(250), MSGID_PROD VARCHAR(250),
> MSGID_SEQ INTEGER, EXPIRATION BIGINT, MSG BLOB, PRIMARY KEY
> ( ID ) ) Message: Table/View 'ACTIVEMQ_MSGS' already exists in
> Schema 'APP'. SQLState: X0Y32 Vendor code: 20000
> 17:39:10.215 main
> org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
> doCreateTables :Executing SQL: CREATE INDEX ACTIVEMQ_MSGS_MIDX ON
> ACTIVEMQ_MSGS (MSGID_PROD,MSGID_SEQ)
> 17:39:10.285 main
> org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
> doCreateTables :Executing SQL: CREATE INDEX ACTIVEMQ_MSGS_CIDX ON
> ACTIVEMQ_MSGS (CONTAINER)
> 17:39:10.332 main
> org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
> doCreateTables :Executing SQL: CREATE INDEX ACTIVEMQ_MSGS_EIDX ON
> ACTIVEMQ_MSGS (EXPIRATION)
> 17:39:10.355 main
> org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
> doCreateTables :Executing SQL: CREATE TABLE ACTIVEMQ_ACKS(CONTAINER
> VARCHAR(250) NOT NULL, CLIENT_ID VARCHAR(250) NOT NULL, SUB_NAME
> VARCHAR(250) NOT NULL, SELECTOR VARCHAR(250), LAST_ACKED_ID
> INTEGER, PRIMARY KEY ( CONTAINER, CLIENT_ID, SUB_NAME))
> 17:39:10.634 main
> org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
> doCreateTables :Could not create JDBC tables; The message table
> already existed. Failure was: CREATE TABLE ACTIVEMQ_ACKS(CONTAINER
> VARCHAR(250) NOT NULL, CLIENT_ID VARCHAR(250) NOT NULL, SUB_NAME
> VARCHAR(250) NOT NULL, SELECTOR VARCHAR(250), LAST_ACKED_ID
> INTEGER, PRIMARY KEY ( CONTAINER, CLIENT_ID, SUB_NAME)) Message:
> Table/View 'ACTIVEMQ_ACKS' already exists in Schema 'APP'.
> SQLState: X0Y32 Vendor code: 20000
> 17:39:10.635 main
> org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
> doCreateTables :Executing SQL: CREATE TABLE ACTIVEMQ_LOCK( ID
> BIGINT NOT NULL, TIME BIGINT, BROKER_NAME VARCHAR(250), PRIMARY KEY
> (ID) )
> 17:39:10.880 main
> org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
> doCreateTables :Could not create JDBC tables; The message table
> already existed. Failure was: CREATE TABLE ACTIVEMQ_LOCK( ID BIGINT
> NOT NULL, TIME BIGINT, BROKER_NAME VARCHAR(250), PRIMARY KEY (ID) )
> Message: Table/View 'ACTIVEMQ_LOCK' already exists in Schema 'APP'.
> SQLState: X0Y32 Vendor code: 20000
> 17:39:10.881 main
> org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
> doCreateTables :Executing SQL: INSERT INTO ACTIVEMQ_LOCK(ID) VALUES
> (1)
>
>
> come the Master broker
> 17:39:11.239 main
> org.apache.activemq.store.jdbc.DefaultDatabaseLocker
> start :Becoming the master on dataSource:
> org.apache.derby.jdbc.EmbeddedDataSource@682406
> 17:39:11.240 main
> org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
> cleanup :Cleaning up old messages.
> 17:39:11.241 main
> org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
> doDeleteOldMessages :Executing SQL: DELETE FROM ACTIVEMQ_MSGS WHERE
> ( EXPIRATION<>0 AND EXPIRATION<?) OR ID <= ( SELECT min
> (ACTIVEMQ_ACKS.LAST_ACKED_ID) FROM ACTIVEMQ_ACKS WHERE
> ACTIVEMQ_ACKS.CONTAINER=ACTIVEMQ_MSGS.CONTAINER)
> 17:39:11.370 main
> org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
> doDeleteOldMessages :Deleted 0 old message(s).
> 17:39:11.372 main
> org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
> cleanup :Cleanup done.
> 17:39:11.374 main
> org.apache.activemq.store.journal.JournalPersistenceAdapter
> recover :Journal Recovery Started from: Active Journal: using 2 x
> 20.0 Megs at: /.automount/vincent/export/home/t/tonyqian/PHONEHOME/
> phonehome/activemq-data/localhost/journal
> 17:39:11.397 main
> org.apache.activemq.store.journal.JournalPersistenceAdapter
> recover :TRACE Entry: RECOVERED
> 17:39:11.472 main
> org.apache.activemq.store.journal.JournalPersistenceAdapter
> recover :Journal Recovered: 0 message(s) in transactions recovered.
> 17:39:11.715 main org.apache.activemq.broker.BrokerService
> start :ActiveMQ JMS Message Broker (localhost,
> ID:walker.office.compuserve.com-42526-1169678343087-1:0) started
> 17:39:11.716 main
> org.apache.activemq.transport.vm.VMTransportFactory bind :binding
> to broker: localhost
> 17:39:11.731 main org.apache.activemq.broker.TransportConnector
> start :Connector vm://localhost Started
> 17:39:11.806 main com.netscape.isp.phonehome.jms.JMSConnection
> connect: JMSConnection(): Exception: null. Can't connect to JMS server
> 17:39:11.807 main com.netscape.isp.phonehome.jms.JMSConnection
> getQueue :JMSConnection.getQueue(): Looking up queue
> 17:39:11.810 main com.netscape.isp.phonehome.jms.JMSReceiver
> <init> :JMSReceiver(): Exception: queue is null
>
>
>
Re: a new jms broker started by Consumer
Posted by Rob Davies <ra...@gmail.com>.
Hi Tony,
well, maybe I responded too quickly. This certainly looks like
another issue that was in 4.1 - but without more details I can't be
certain
You can get snapshots here: http://people.apache.org/repo/m2-
snapshot-repository/org/apache/activemq/apache-activemq/
cheers,
Rob
On 25 Jan 2007, at 14:35, Tony Qian wrote:
> Rob,
>
> Appreciate your quick response. What's still puzzling me is why the
> example code works.
>
> Has version 4.2 been released? I didn't see the download link for
> version 4.2. If I need to build it by myself, how do i do it?
>
> thanks,
> Tony
>
> Rob Davies wrote on 1/25/2007, 9:19 AM:
>
>> Gulp! - a known issue this is fixed in 4.2
>> cheers,
>>
>> Rob
>> On 25 Jan 2007, at 14:16, Tony Qian wrote:
>>
>>> All,
>>>
>>> Sorry for long message. I tried to set up ActiveMQ broker and got
>>> following error when try to create a connection at consumer side.
>>>
>>> ActiveMQConnectionFactory factory = new
>>> ActiveMQConnectionFactory("tcp://localhost:61616");
>>> connection = factory.createQueueConnection();
>>>
>>> I don't understand why consumer tried to create database. Why did
>>> it start a JMS broker. Error msg is attached.
>>>
>>> Appreciate your help.
>>> Tony
>>>
>>> 17:39:02.697 main org.apache.activemq.broker.jmx.ManagementContext
>>> createConnector :Failed to create local registry
>>> java.rmi.server.ExportException: Port already in use: 1099; nested
>>> exception is:
>>> java.net.BindException: Address already in use
>>> at sun.rmi.transport.tcp.TCPTransport.listen
>>> (TCPTransport.java:243)
>>> at sun.rmi.transport.tcp.TCPTransport.exportObject
>>> (TCPTransport.java:178)
>>> at sun.rmi.transport.tcp.TCPEndpoint.exportObject
>>> (TCPEndpoint.java:382)
>>> at sun.rmi.transport.LiveRef.exportObject(LiveRef.java:116)
>>> at sun.rmi.server.UnicastServerRef.exportObject
>>> (UnicastServerRef.java:145)
>>> at sun.rmi.registry.RegistryImpl.setup(RegistryImpl.java:92)
>>> at sun.rmi.registry.RegistryImpl.<init>(RegistryImpl.java:
>>> 78)
>>> at java.rmi.registry.LocateRegistry.createRegistry
>>> (LocateRegistry.java:164)
>>> at
>>> org.apache.activemq.broker.jmx.ManagementContext.createConnector
>>> (ManagementContext.java:382)
>>> at
>>> org.apache.activemq.broker.jmx.ManagementContext.createMBeanServer
>>> (ManagementContext.java:367)
>>> at
>>> org.apache.activemq.broker.jmx.ManagementContext.findMBeanServer
>>> (ManagementContext.java:297)
>>> at
>>> org.apache.activemq.broker.jmx.ManagementContext.getMBeanServer
>>> (ManagementContext.java:154)
>>> at org.apache.activemq.broker.jmx.ManagementContext.start
>>> (ManagementContext.java:78)
>>> at org.apache.activemq.broker.BrokerService.start
>>> (BrokerService.java:391)
>>> at
>>> org.apache.activemq.transport.vm.VMTransportFactory.doCompositeConne
>>> ct
>>> (VMTransportFactory.java:113)
>>> at
>>> org.apache.activemq.transport.vm.VMTransportFactory.doConnect
>>> (VMTransportFactory.java:52)
>>> at org.apache.activemq.transport.TransportFactory.doConnect
>>> (TransportFactory.java:43)
>>> at org.apache.activemq.transport.TransportFactory.connect
>>> (TransportFactory.java:77)
>>> at
>>> org.apache.activemq.ActiveMQConnectionFactory.createTransport
>>> (ActiveMQConnectionFactory.java:227)
>>> at
>>> org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnecti
>>> on
>>> (ActiveMQConnectionFactory.java:242)
>>> at
>>> org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnecti
>>> on
>>> (ActiveMQConnectionFactory.java:211)
>>> at
>>> org.apache.activemq.ActiveMQConnectionFactory.createQueueConnection
>>> (ActiveMQConnectionFactory.java:173)
>>> at .jms.JMSConnection.connect(Unknown Source)
>>> at jms.JMSConnection.<init>(Unknown Source)
>>> at .jms.JMSConnection.<clinit>(Unknown Source)
>>> at jms.JMSReceiver.<init>(Unknown Source)
>>> at jms.JMSReceiver.<init>(Unknown Source)
>>> at .PhoneHomeQueueListener.<init>(Unknown Source)
>>> ....
>>>
>>> 17:39:03.031 main org.apache.activemq.broker.BrokerService
>>> getBroker :ActiveMQ 4.1.0-incubator JMS Message Broker (localhost)
>>> is starting
>>> 17:39:03.032 main org.apache.activemq.broker.BrokerService
>>> getBroker :For help or more information please see: http://
>>> incubator.apache.org/activemq/
>>> 17:39:03.376 JMX connector
>>> org.apache.activemq.broker.jmx.ManagementContext$1 run :Failed to
>>> start jmx connector: javax.naming.NameAlreadyBoundException: jmxrmi
>>> [Root exception is java.rmi.AlreadyBoundException: jmxrmi]
>>> 17:39:07.309 main
>>> org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
>>> createAdapter :Database driver recognized:
>>> [apache_derby_embedded_jdbc_driver]
>>> 17:39:09.706 main
>>> org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
>>> doCreateTables :Executing SQL: CREATE TABLE ACTIVEMQ_MSGS(ID
>>> INTEGER NOT NULL, CONTAINER VARCHAR(250), MSGID_PROD VARCHAR(250),
>>> MSGID_SEQ INTEGER, EXPIRATION BIGINT, MSG BLOB, PRIMARY KEY ( ID ) )
>>> 17:39:10.214 main
>>> org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
>>> doCreateTables :Could not create JDBC tables; The message table
>>> already existed. Failure was: CREATE TABLE ACTIVEMQ_MSGS(ID INTEGER
>>> NOT NULL, CONTAINER VARCHAR(250), MSGID_PROD VARCHAR(250),
>>> MSGID_SEQ INTEGER, EXPIRATION BIGINT, MSG BLOB, PRIMARY KEY
>>> ( ID ) ) Message: Table/View 'ACTIVEMQ_MSGS' already exists in
>>> Schema 'APP'. SQLState: X0Y32 Vendor code: 20000
>>> 17:39:10.215 main
>>> org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
>>> doCreateTables :Executing SQL: CREATE INDEX ACTIVEMQ_MSGS_MIDX ON
>>> ACTIVEMQ_MSGS (MSGID_PROD,MSGID_SEQ)
>>> 17:39:10.285 main
>>> org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
>>> doCreateTables :Executing SQL: CREATE INDEX ACTIVEMQ_MSGS_CIDX ON
>>> ACTIVEMQ_MSGS (CONTAINER)
>>> 17:39:10.332 main
>>> org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
>>> doCreateTables :Executing SQL: CREATE INDEX ACTIVEMQ_MSGS_EIDX ON
>>> ACTIVEMQ_MSGS (EXPIRATION)
>>> 17:39:10.355 main
>>> org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
>>> doCreateTables :Executing SQL: CREATE TABLE ACTIVEMQ_ACKS(CONTAINER
>>> VARCHAR(250) NOT NULL, CLIENT_ID VARCHAR(250) NOT NULL, SUB_NAME
>>> VARCHAR(250) NOT NULL, SELECTOR VARCHAR(250), LAST_ACKED_ID
>>> INTEGER, PRIMARY KEY ( CONTAINER, CLIENT_ID, SUB_NAME))
>>> 17:39:10.634 main
>>> org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
>>> doCreateTables :Could not create JDBC tables; The message table
>>> already existed. Failure was: CREATE TABLE ACTIVEMQ_ACKS(CONTAINER
>>> VARCHAR(250) NOT NULL, CLIENT_ID VARCHAR(250) NOT NULL, SUB_NAME
>>> VARCHAR(250) NOT NULL, SELECTOR VARCHAR(250), LAST_ACKED_ID
>>> INTEGER, PRIMARY KEY ( CONTAINER, CLIENT_ID, SUB_NAME)) Message:
>>> Table/View 'ACTIVEMQ_ACKS' already exists in Schema 'APP'.
>>> SQLState: X0Y32 Vendor code: 20000
>>> 17:39:10.635 main
>>> org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
>>> doCreateTables :Executing SQL: CREATE TABLE ACTIVEMQ_LOCK( ID
>>> BIGINT NOT NULL, TIME BIGINT, BROKER_NAME VARCHAR(250), PRIMARY KEY
>>> (ID) )
>>> 17:39:10.880 main
>>> org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
>>> doCreateTables :Could not create JDBC tables; The message table
>>> already existed. Failure was: CREATE TABLE ACTIVEMQ_LOCK( ID BIGINT
>>> NOT NULL, TIME BIGINT, BROKER_NAME VARCHAR(250), PRIMARY KEY (ID) )
>>> Message: Table/View 'ACTIVEMQ_LOCK' already exists in Schema 'APP'.
>>> SQLState: X0Y32 Vendor code: 20000
>>> 17:39:10.881 main
>>> org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
>>> doCreateTables :Executing SQL: INSERT INTO ACTIVEMQ_LOCK(ID) VALUES
>>> (1)
>>>
>>>
>>> come the Master broker
>>> 17:39:11.239 main
>>> org.apache.activemq.store.jdbc.DefaultDatabaseLocker
>>> start :Becoming the master on dataSource:
>>> org.apache.derby.jdbc.EmbeddedDataSource@682406
>>> 17:39:11.240 main
>>> org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
>>> cleanup :Cleaning up old messages.
>>> 17:39:11.241 main
>>> org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
>>> doDeleteOldMessages :Executing SQL: DELETE FROM ACTIVEMQ_MSGS WHERE
>>> ( EXPIRATION<>0 AND EXPIRATION<?) OR ID <= ( SELECT min
>>> (ACTIVEMQ_ACKS.LAST_ACKED_ID) FROM ACTIVEMQ_ACKS WHERE
>>> ACTIVEMQ_ACKS.CONTAINER=ACTIVEMQ_MSGS.CONTAINER)
>>> 17:39:11.370 main
>>> org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
>>> doDeleteOldMessages :Deleted 0 old message(s).
>>> 17:39:11.372 main
>>> org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
>>> cleanup :Cleanup done.
>>> 17:39:11.374 main
>>> org.apache.activemq.store.journal.JournalPersistenceAdapter
>>> recover :Journal Recovery Started from: Active Journal: using 2 x
>>> 20.0 Megs at: /.automount/vincent/export/home/t/tonyqian/PHONEHOME/
>>> phonehome/activemq-data/localhost/journal
>>> 17:39:11.397 main
>>> org.apache.activemq.store.journal.JournalPersistenceAdapter
>>> recover :TRACE Entry: RECOVERED
>>> 17:39:11.472 main
>>> org.apache.activemq.store.journal.JournalPersistenceAdapter
>>> recover :Journal Recovered: 0 message(s) in transactions recovered.
>>> 17:39:11.715 main org.apache.activemq.broker.BrokerService
>>> start :ActiveMQ JMS Message Broker (localhost,
>>> ID:walker.office.compuserve.com-42526-1169678343087-1:0) started
>>> 17:39:11.716 main
>>> org.apache.activemq.transport.vm.VMTransportFactory bind :binding
>>> to broker: localhost
>>> 17:39:11.731 main org.apache.activemq.broker.TransportConnector
>>> start :Connector vm://localhost Started
>>> 17:39:11.806 main com.netscape.isp.phonehome.jms.JMSConnection
>>> connect: JMSConnection(): Exception: null. Can't connect to JMS
>>> server
>>> 17:39:11.807 main com.netscape.isp.phonehome.jms.JMSConnection
>>> getQueue :JMSConnection.getQueue(): Looking up queue
>>> 17:39:11.810 main com.netscape.isp.phonehome.jms.JMSReceiver
>>> <init> :JMSReceiver(): Exception: queue is null
>>>
>>>
>>>
>>
>
>
Re: a new jms broker started by Consumer
Posted by Tony Qian <da...@aol.com>.
Rob,
Appreciate your quick response. What's still puzzling me is why the
example code works.
Has version 4.2 been released? I didn't see the download link for
version 4.2. If I need to build it by myself, how do i do it?
thanks,
Tony
Rob Davies wrote on 1/25/2007, 9:19 AM:
> Gulp! - a known issue this is fixed in 4.2
> cheers,
>
> Rob
> On 25 Jan 2007, at 14:16, Tony Qian wrote:
>
> > All,
> >
> > Sorry for long message. I tried to set up ActiveMQ broker and got
> > following error when try to create a connection at consumer side.
> >
> > ActiveMQConnectionFactory factory = new
> > ActiveMQConnectionFactory("tcp://localhost:61616");
> > connection = factory.createQueueConnection();
> >
> > I don't understand why consumer tried to create database. Why did
> > it start a JMS broker. Error msg is attached.
> >
> > Appreciate your help.
> > Tony
> >
> > 17:39:02.697 main org.apache.activemq.broker.jmx.ManagementContext
> > createConnector :Failed to create local registry
> > java.rmi.server.ExportException: Port already in use: 1099; nested
> > exception is:
> > java.net.BindException: Address already in use
> > at sun.rmi.transport.tcp.TCPTransport.listen
> > (TCPTransport.java:243)
> > at sun.rmi.transport.tcp.TCPTransport.exportObject
> > (TCPTransport.java:178)
> > at sun.rmi.transport.tcp.TCPEndpoint.exportObject
> > (TCPEndpoint.java:382)
> > at sun.rmi.transport.LiveRef.exportObject(LiveRef.java:116)
> > at sun.rmi.server.UnicastServerRef.exportObject
> > (UnicastServerRef.java:145)
> > at sun.rmi.registry.RegistryImpl.setup(RegistryImpl.java:92)
> > at sun.rmi.registry.RegistryImpl.<init>(RegistryImpl.java:78)
> > at java.rmi.registry.LocateRegistry.createRegistry
> > (LocateRegistry.java:164)
> > at
> > org.apache.activemq.broker.jmx.ManagementContext.createConnector
> > (ManagementContext.java:382)
> > at
> > org.apache.activemq.broker.jmx.ManagementContext.createMBeanServer
> > (ManagementContext.java:367)
> > at
> > org.apache.activemq.broker.jmx.ManagementContext.findMBeanServer
> > (ManagementContext.java:297)
> > at
> > org.apache.activemq.broker.jmx.ManagementContext.getMBeanServer
> > (ManagementContext.java:154)
> > at org.apache.activemq.broker.jmx.ManagementContext.start
> > (ManagementContext.java:78)
> > at org.apache.activemq.broker.BrokerService.start
> > (BrokerService.java:391)
> > at
> > org.apache.activemq.transport.vm.VMTransportFactory.doCompositeConnect
> > (VMTransportFactory.java:113)
> > at
> > org.apache.activemq.transport.vm.VMTransportFactory.doConnect
> > (VMTransportFactory.java:52)
> > at org.apache.activemq.transport.TransportFactory.doConnect
> > (TransportFactory.java:43)
> > at org.apache.activemq.transport.TransportFactory.connect
> > (TransportFactory.java:77)
> > at
> > org.apache.activemq.ActiveMQConnectionFactory.createTransport
> > (ActiveMQConnectionFactory.java:227)
> > at
> > org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection
> > (ActiveMQConnectionFactory.java:242)
> > at
> > org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection
> > (ActiveMQConnectionFactory.java:211)
> > at
> > org.apache.activemq.ActiveMQConnectionFactory.createQueueConnection
> > (ActiveMQConnectionFactory.java:173)
> > at .jms.JMSConnection.connect(Unknown Source)
> > at jms.JMSConnection.<init>(Unknown Source)
> > at .jms.JMSConnection.<clinit>(Unknown Source)
> > at jms.JMSReceiver.<init>(Unknown Source)
> > at jms.JMSReceiver.<init>(Unknown Source)
> > at .PhoneHomeQueueListener.<init>(Unknown Source)
> > ....
> >
> > 17:39:03.031 main org.apache.activemq.broker.BrokerService
> > getBroker :ActiveMQ 4.1.0-incubator JMS Message Broker (localhost)
> > is starting
> > 17:39:03.032 main org.apache.activemq.broker.BrokerService
> > getBroker :For help or more information please see: http://
> > incubator.apache.org/activemq/
> > 17:39:03.376 JMX connector
> > org.apache.activemq.broker.jmx.ManagementContext$1 run :Failed to
> > start jmx connector: javax.naming.NameAlreadyBoundException: jmxrmi
> > [Root exception is java.rmi.AlreadyBoundException: jmxrmi]
> > 17:39:07.309 main
> > org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
> > createAdapter :Database driver recognized:
> > [apache_derby_embedded_jdbc_driver]
> > 17:39:09.706 main
> > org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
> > doCreateTables :Executing SQL: CREATE TABLE ACTIVEMQ_MSGS(ID
> > INTEGER NOT NULL, CONTAINER VARCHAR(250), MSGID_PROD VARCHAR(250),
> > MSGID_SEQ INTEGER, EXPIRATION BIGINT, MSG BLOB, PRIMARY KEY ( ID ) )
> > 17:39:10.214 main
> > org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
> > doCreateTables :Could not create JDBC tables; The message table
> > already existed. Failure was: CREATE TABLE ACTIVEMQ_MSGS(ID INTEGER
> > NOT NULL, CONTAINER VARCHAR(250), MSGID_PROD VARCHAR(250),
> > MSGID_SEQ INTEGER, EXPIRATION BIGINT, MSG BLOB, PRIMARY KEY
> > ( ID ) ) Message: Table/View 'ACTIVEMQ_MSGS' already exists in
> > Schema 'APP'. SQLState: X0Y32 Vendor code: 20000
> > 17:39:10.215 main
> > org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
> > doCreateTables :Executing SQL: CREATE INDEX ACTIVEMQ_MSGS_MIDX ON
> > ACTIVEMQ_MSGS (MSGID_PROD,MSGID_SEQ)
> > 17:39:10.285 main
> > org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
> > doCreateTables :Executing SQL: CREATE INDEX ACTIVEMQ_MSGS_CIDX ON
> > ACTIVEMQ_MSGS (CONTAINER)
> > 17:39:10.332 main
> > org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
> > doCreateTables :Executing SQL: CREATE INDEX ACTIVEMQ_MSGS_EIDX ON
> > ACTIVEMQ_MSGS (EXPIRATION)
> > 17:39:10.355 main
> > org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
> > doCreateTables :Executing SQL: CREATE TABLE ACTIVEMQ_ACKS(CONTAINER
> > VARCHAR(250) NOT NULL, CLIENT_ID VARCHAR(250) NOT NULL, SUB_NAME
> > VARCHAR(250) NOT NULL, SELECTOR VARCHAR(250), LAST_ACKED_ID
> > INTEGER, PRIMARY KEY ( CONTAINER, CLIENT_ID, SUB_NAME))
> > 17:39:10.634 main
> > org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
> > doCreateTables :Could not create JDBC tables; The message table
> > already existed. Failure was: CREATE TABLE ACTIVEMQ_ACKS(CONTAINER
> > VARCHAR(250) NOT NULL, CLIENT_ID VARCHAR(250) NOT NULL, SUB_NAME
> > VARCHAR(250) NOT NULL, SELECTOR VARCHAR(250), LAST_ACKED_ID
> > INTEGER, PRIMARY KEY ( CONTAINER, CLIENT_ID, SUB_NAME)) Message:
> > Table/View 'ACTIVEMQ_ACKS' already exists in Schema 'APP'.
> > SQLState: X0Y32 Vendor code: 20000
> > 17:39:10.635 main
> > org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
> > doCreateTables :Executing SQL: CREATE TABLE ACTIVEMQ_LOCK( ID
> > BIGINT NOT NULL, TIME BIGINT, BROKER_NAME VARCHAR(250), PRIMARY KEY
> > (ID) )
> > 17:39:10.880 main
> > org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
> > doCreateTables :Could not create JDBC tables; The message table
> > already existed. Failure was: CREATE TABLE ACTIVEMQ_LOCK( ID BIGINT
> > NOT NULL, TIME BIGINT, BROKER_NAME VARCHAR(250), PRIMARY KEY (ID) )
> > Message: Table/View 'ACTIVEMQ_LOCK' already exists in Schema 'APP'.
> > SQLState: X0Y32 Vendor code: 20000
> > 17:39:10.881 main
> > org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
> > doCreateTables :Executing SQL: INSERT INTO ACTIVEMQ_LOCK(ID) VALUES
> > (1)
> >
> >
> > come the Master broker
> > 17:39:11.239 main
> > org.apache.activemq.store.jdbc.DefaultDatabaseLocker
> > start :Becoming the master on dataSource:
> > org.apache.derby.jdbc.EmbeddedDataSource@682406
> > 17:39:11.240 main
> > org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
> > cleanup :Cleaning up old messages.
> > 17:39:11.241 main
> > org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
> > doDeleteOldMessages :Executing SQL: DELETE FROM ACTIVEMQ_MSGS WHERE
> > ( EXPIRATION<>0 AND EXPIRATION<?) OR ID <= ( SELECT min
> > (ACTIVEMQ_ACKS.LAST_ACKED_ID) FROM ACTIVEMQ_ACKS WHERE
> > ACTIVEMQ_ACKS.CONTAINER=ACTIVEMQ_MSGS.CONTAINER)
> > 17:39:11.370 main
> > org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
> > doDeleteOldMessages :Deleted 0 old message(s).
> > 17:39:11.372 main
> > org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
> > cleanup :Cleanup done.
> > 17:39:11.374 main
> > org.apache.activemq.store.journal.JournalPersistenceAdapter
> > recover :Journal Recovery Started from: Active Journal: using 2 x
> > 20.0 Megs at: /.automount/vincent/export/home/t/tonyqian/PHONEHOME/
> > phonehome/activemq-data/localhost/journal
> > 17:39:11.397 main
> > org.apache.activemq.store.journal.JournalPersistenceAdapter
> > recover :TRACE Entry: RECOVERED
> > 17:39:11.472 main
> > org.apache.activemq.store.journal.JournalPersistenceAdapter
> > recover :Journal Recovered: 0 message(s) in transactions recovered.
> > 17:39:11.715 main org.apache.activemq.broker.BrokerService
> > start :ActiveMQ JMS Message Broker (localhost,
> > ID:walker.office.compuserve.com-42526-1169678343087-1:0) started
> > 17:39:11.716 main
> > org.apache.activemq.transport.vm.VMTransportFactory bind :binding
> > to broker: localhost
> > 17:39:11.731 main org.apache.activemq.broker.TransportConnector
> > start :Connector vm://localhost Started
> > 17:39:11.806 main com.netscape.isp.phonehome.jms.JMSConnection
> > connect: JMSConnection(): Exception: null. Can't connect to JMS server
> > 17:39:11.807 main com.netscape.isp.phonehome.jms.JMSConnection
> > getQueue :JMSConnection.getQueue(): Looking up queue
> > 17:39:11.810 main com.netscape.isp.phonehome.jms.JMSReceiver
> > <init> :JMSReceiver(): Exception: queue is null
> >
> >
> >
>