Re: a new jms broker started by Consumer

Thu, 25 Jan 2007 06:53:29 -0800 

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:
[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