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




Reply via email to