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:
> > [EMAIL PROTECTED]
> > 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
> >
> >
> >
>
