activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Rob Davies <rajdav...@gmail.com>
Subject Re: a new jms broker started by Consumer
Date Thu, 25 Jan 2007 14:52:24 GMT
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
>>>
>>>
>>>
>>
>
>


Mime
View raw message