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
- a new jms broker started by Consumer Tony Qian
- Re: a new jms broker started by Consumer Rob Davies
- Re: a new jms broker started by Consumer Tony Qian
- Re: a new jms broker started by Consumer Rob Davies
