Axel Podehl created AMQ-4626:
--------------------------------
Summary: AMQP broker prints producer's connection id to stdout
Key: AMQ-4626
URL: https://issues.apache.org/jira/browse/AMQ-4626
Project: ActiveMQ
Issue Type: Bug
Components: Broker
Affects Versions: 5.9.0
Environment: Windows 7
Reporter: Axel Podehl
Priority: Minor
Hi,
I'm using an AMQP transport connector in an embedded Broker, but whenever a
producer is connecting the connection id appears on standard out. Probably some
left-over of some debugging code ?
I tested also with the latest 5.9.0 snapshot from 7/9/2013 and it's still there.
My code is something like this:
String amqpURI = "amqp://0.0.0.0:" + amqpPort +
"?maximumConnections=1000&wireformat.maxFrameSize=104857600";
logInfo("ActiveMQ: adding AMQP transport: " + amqpURI );
TransportConnector amqpConnector = new TransportConnector();
amqpConnector.setName("amqp");
amqpConnector.setUri( new URI(amqpURI) );
activeMqBroker.addConnector(amqpConnector);
and once a QPID amqp_1_0 producer connects, I see this (added newlines for
clarity):
7924 [ActiveMQ BrokerService[localhost] Task-2] DEBUG
org.apache.activemq.broker.region.Queue - TEST toPageIn: 11, Inflight: 0,
pagedInMessages.size 0, enqueueCount: 10, dequeueCount: 0
ID:Berlin-60845-1373442523293-2:1:0
----------- full trace (with some of my own logs in between):
Starting ActiveMQ Broker, see
C:\CodeStreet\ReplayServiceJMS\bin\log\channel-jni.log
0 [main] INFO ChannelJNI - ### Starting ActiveMQ broker with broker url:
broker:(tcp://localhost:51515)?useJmx=true and parameters:
persistent=true,memory=64mb,store=1GB,temp=100mb,amqpPort=5672
171 [main] INFO org.apache.activemq.store.kahadb.plist.PListStoreImpl -
PListStore:[C:\CodeStreet\ReplayServiceJMS\bin\activemq-data\localhost\tmp_storage]
started
179 [main] INFO ChannelJNI - ActiveMQ: adding AMQP transport:
amqp://0.0.0.0:5672?maximumConnections=1000&wireformat.maxFrameSize=104857600
179 [main] INFO ChannelJNI - network connectors: []
179 [main] INFO ChannelJNI - transport connectors: [tcp://127.0.0.1:51515,
amqp]
225 [main] DEBUG org.apache.activemq.broker.jmx.ManagementContext - Creating
RMIRegistry on port 1099
258 [main] DEBUG org.apache.activemq.broker.jmx.ManagementContext - Probably
not using JRE 1.4: mx4j.tools.naming.NamingService
261 [main] DEBUG org.apache.activemq.broker.jmx.ManagementContext - Created
JMXConnectorServer javax.management.remote.rmi.RMIConnectorServer@4979935d
262 [JMX connector] DEBUG org.apache.activemq.broker.jmx.ManagementContext -
Starting JMXConnectorServer...
335 [main] INFO org.apache.activemq.broker.BrokerService - Using Persistence
Adapter:
KahaDBPersistenceAdapter[C:\CodeStreet\ReplayServiceJMS\bin\activemq-data\localhost\KahaDB]
336 [JMX connector] INFO org.apache.activemq.broker.jmx.ManagementContext -
JMX consoles can connect to service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi
690 [main] DEBUG org.apache.activemq.store.kahadb.disk.page.PageFile - Page
File: activemq-data\localhost\KahaDB\db.data, Recovering page file...
700 [main] INFO org.apache.activemq.store.kahadb.MessageDatabase - KahaDB is
version 4
701 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
706 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
706 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
706 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
707 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
707 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
707 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
707 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
707 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
707 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
707 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
708 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
708 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
709 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.ListIndex -
loading
711 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
711 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
711 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
712 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
712 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
712 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
712 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
712 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.ListIndex -
loading
712 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
712 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
712 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
712 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
712 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
712 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
712 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
712 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.ListIndex -
loading
713 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
713 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
713 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
713 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
713 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
713 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
713 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
713 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.ListIndex -
loading
713 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
713 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
713 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
714 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
714 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
714 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
714 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
714 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.ListIndex -
loading
714 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
714 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
714 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
714 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
714 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
714 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
714 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
715 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.ListIndex -
loading
715 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
715 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
715 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
715 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
715 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
715 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
715 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex -
loading
715 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.ListIndex -
loading
730 [main] INFO org.apache.activemq.store.kahadb.MessageDatabase - Recovering
from the journal ...
740 [main] INFO org.apache.activemq.store.kahadb.MessageDatabase - Recovery
replayed 23 operations from the journal in 0.024 seconds.
929 [main] INFO org.apache.activemq.broker.BrokerService - Apache ActiveMQ
5.8.0 (localhost, ID:Berlin-60845-1373442523293-0:1) is starting
934 [main] DEBUG org.apache.activemq.broker.region.AbstractRegion - localhost
adding destination: queue://TEST
957 [main] DEBUG org.apache.activemq.thread.TaskRunnerFactory - Initialized
TaskRunnerFactory[ActiveMQ BrokerService[localhost] Task] using
ExecutorService: java.util.concurrent.ThreadPoolExecutor@26a3960
993 [main] DEBUG org.apache.activemq.broker.region.Queue - TEST toPageIn: 1,
Inflight: 0, pagedInMessages.size 0, enqueueCount: 0, dequeueCount: 0
1003 [main] DEBUG org.apache.activemq.broker.region.Queue - TEST toPageIn: 1,
Inflight: 0, pagedInMessages.size 0, enqueueCount: 0, dequeueCount: 0
1007 [main] DEBUG org.apache.activemq.broker.TransportConnector - Publishing:
tcp://127.0.0.1:51515 for broker transport URI: tcp://127.0.0.1:51515
1007 [main] DEBUG org.apache.activemq.broker.TransportConnector - Publishing:
amqp://0.0.0.0:5672 for broker transport URI:
amqp://0.0.0.0:5672?maximumConnections=1000&wireformat.maxFrameSize=104857600
1008 [main] INFO org.apache.activemq.transport.TransportServerThreadSupport -
Listening for connections at: tcp://127.0.0.1:51515
1009 [main] INFO org.apache.activemq.broker.TransportConnector - Connector
tcp://127.0.0.1:51515 Started
1015 [main] INFO org.apache.activemq.transport.TransportServerThreadSupport -
Listening for connections at:
amqp://Berlin:5672?maximumConnections=1000&wireformat.maxFrameSize=104857600
1015 [main] INFO org.apache.activemq.broker.TransportConnector - Connector
amqp Started
1017 [main] INFO org.apache.activemq.broker.BrokerService - Apache ActiveMQ
5.8.0 (localhost, ID:Berlin-60845-1373442523293-0:1) started
1017 [main] INFO org.apache.activemq.broker.BrokerService - For help or more
information please see: http://activemq.apache.org
1020 [main] DEBUG org.apache.activemq.broker.region.AbstractRegion - localhost
adding destination: topic://ActiveMQ.Advisory.MasterBroker
1039 [main] INFO ChannelJNI - ActiveMQ Broker Version: 5.8.0
1039 [main] INFO ChannelJNI - ActiveMQ memory limit: 67108864
1039 [main] INFO ChannelJNI - ActiveMQ memory percent used: 0
1039 [main] INFO ChannelJNI - ActiveMQ persistent: true
1039 [main] INFO ChannelJNI - ActiveMQ sendFailIfNoSpace: false
1039 [main] INFO ChannelJNI - ActiveMQ memory: Usage(Main:memory)
percentUsage=0%, usage=0, limit=67108864, percentUsageMinDelta=1%
1039 [main] INFO ChannelJNI - ActiveMQ store: Usage(Main:store)
percentUsage=0%, usage=265900, limit=1073741824, percentUsageMinDelta=1%
1039 [main] INFO ChannelJNI - ActiveMQ data directory: activemq-data
1039 [main] INFO ChannelJNI - ActiveMQ temp: Usage(Main:temp) percentUsage=0%,
usage=0, limit=104857600, percentUsageMinDelta=1%
1039 [main] INFO ChannelJNI - ActiveMQ temp directory:
activemq-data\localhost\tmp_storage
started
5717 [ActiveMQ Journal Checkpoint Worker] DEBUG
org.apache.activemq.store.kahadb.MessageDatabase - Checkpoint started.
5718 [ActiveMQ Journal Checkpoint Worker] DEBUG
org.apache.activemq.store.kahadb.MessageDatabase - Checkpoint done.
7803 [ActiveMQ Transport: tcp:///127.0.0.1:60846@5672] DEBUG
org.apache.activemq.broker.TransportConnection - Setting up new connection id:
ID:Berlin-60845-1373442523293-2:1, address: tcp://127.0.0.1:60846, info:
ConnectionInfo {commandId = 0, responseRequired = true, connectionId =
ID:Berlin-60845-1373442523293-2:1, clientId = TEST, clientIp = null, userName =
guest, password = *****, brokerPath = null, brokerMasterConnector = false,
manageable = false, clientMaster = true, faultTolerant = false,
failoverReconnect = false}
7803 [ActiveMQ Transport: tcp:///127.0.0.1:60846@5672] DEBUG
org.apache.activemq.broker.region.AbstractRegion - localhost adding
destination: topic://ActiveMQ.Advisory.Connection
7877 [ActiveMQ Transport: tcp:///127.0.0.1:60846@5672] DEBUG
org.apache.activemq.broker.region.AbstractRegion - localhost adding
destination: topic://ActiveMQ.Advisory.Producer.Queue.TEST
7906 [ActiveMQ Transport: tcp:///127.0.0.1:60846@5672] DEBUG
org.apache.activemq.broker.region.Queue - localhost Message
0e7fc3d7-de11-4354-89a7-5773edaa9ba5 sent to queue://TEST
7906 [ActiveMQ BrokerService[localhost] Task-2] DEBUG
org.apache.activemq.broker.region.Queue - TEST toPageIn: 2, Inflight: 0,
pagedInMessages.size 0, enqueueCount: 1, dequeueCount: 0
7909 [ActiveMQ Transport: tcp:///127.0.0.1:60846@5672] DEBUG
org.apache.activemq.broker.region.Queue - localhost Message
d0938476-d96c-4995-a8f9-14fdfc799ab6 sent to queue://TEST
7909 [ActiveMQ BrokerService[localhost] Task-2] DEBUG
org.apache.activemq.broker.region.Queue - TEST toPageIn: 3, Inflight: 0,
pagedInMessages.size 0, enqueueCount: 2, dequeueCount: 0
7911 [ActiveMQ Transport: tcp:///127.0.0.1:60846@5672] DEBUG
org.apache.activemq.broker.region.Queue - localhost Message
7af96bbf-8ced-46db-bac3-0f7caf1f3dff sent to queue://TEST
7911 [ActiveMQ BrokerService[localhost] Task-2] DEBUG
org.apache.activemq.broker.region.Queue - TEST toPageIn: 4, Inflight: 0,
pagedInMessages.size 0, enqueueCount: 3, dequeueCount: 0
7912 [ActiveMQ Transport: tcp:///127.0.0.1:60846@5672] DEBUG
org.apache.activemq.broker.region.Queue - localhost Message
6d99ab81-3692-452f-9f37-c867b4b0e9d2 sent to queue://TEST
7913 [ActiveMQ BrokerService[localhost] Task-2] DEBUG
org.apache.activemq.broker.region.Queue - TEST toPageIn: 5, Inflight: 0,
pagedInMessages.size 0, enqueueCount: 4, dequeueCount: 0
7914 [ActiveMQ Transport: tcp:///127.0.0.1:60846@5672] DEBUG
org.apache.activemq.broker.region.Queue - localhost Message
9065af75-3067-4562-a2c9-23dc23860408 sent to queue://TEST
7914 [ActiveMQ BrokerService[localhost] Task-2] DEBUG
org.apache.activemq.broker.region.Queue - TEST toPageIn: 6, Inflight: 0,
pagedInMessages.size 0, enqueueCount: 5, dequeueCount: 0
7916 [ActiveMQ Transport: tcp:///127.0.0.1:60846@5672] DEBUG
org.apache.activemq.broker.region.Queue - localhost Message
ac144f32-9355-4662-adb9-5cd16b86e6d0 sent to queue://TEST
7916 [ActiveMQ BrokerService[localhost] Task-2] DEBUG
org.apache.activemq.broker.region.Queue - TEST toPageIn: 7, Inflight: 0,
pagedInMessages.size 0, enqueueCount: 6, dequeueCount: 0
7918 [ActiveMQ Transport: tcp:///127.0.0.1:60846@5672] DEBUG
org.apache.activemq.broker.region.Queue - localhost Message
dfd673af-7553-4967-a98f-90aebb98e2af sent to queue://TEST
7918 [ActiveMQ BrokerService[localhost] Task-2] DEBUG
org.apache.activemq.broker.region.Queue - TEST toPageIn: 8, Inflight: 0,
pagedInMessages.size 0, enqueueCount: 7, dequeueCount: 0
7920 [ActiveMQ Transport: tcp:///127.0.0.1:60846@5672] DEBUG
org.apache.activemq.broker.region.Queue - localhost Message
5677d1bf-4a7b-4dba-8378-f36c2d2f4bfb sent to queue://TEST
7921 [ActiveMQ BrokerService[localhost] Task-2] DEBUG
org.apache.activemq.broker.region.Queue - TEST toPageIn: 9, Inflight: 0,
pagedInMessages.size 0, enqueueCount: 8, dequeueCount: 0
7922 [ActiveMQ Transport: tcp:///127.0.0.1:60846@5672] DEBUG
org.apache.activemq.broker.region.Queue - localhost Message
cc82e930-1c8a-43ce-8990-1e697b8aebf2 sent to queue://TEST
7923 [ActiveMQ BrokerService[localhost] Task-2] DEBUG
org.apache.activemq.broker.region.Queue - TEST toPageIn: 10, Inflight: 0,
pagedInMessages.size 0, enqueueCount: 9, dequeueCount: 0
7924 [ActiveMQ Transport: tcp:///127.0.0.1:60846@5672] DEBUG
org.apache.activemq.broker.region.Queue - localhost Message
306ef2f4-78f1-4842-a17d-1e43a73ea1c1 sent to queue://TEST
7924 [ActiveMQ BrokerService[localhost] Task-2] DEBUG
org.apache.activemq.broker.region.Queue - TEST toPageIn: 11, Inflight: 0,
pagedInMessages.size 0, enqueueCount: 10, dequeueCount: 0
ID:Berlin-60845-1373442523293-2:1:0
7928 [ActiveMQ Transport: tcp:///127.0.0.1:60846@5672] DEBUG
org.apache.activemq.broker.jmx.ManagementContext - Unregistering MBean
org.apache.activemq:type=Broker,brokerName=localhost,destinationType=Queue,destinationName=TEST,endpoint=Producer,clientId=TEST,producerId=ID_Berlin-60845-1373442523293-2_1_0_0
7929 [ActiveMQ Transport: tcp:///127.0.0.1:60846@5672] DEBUG
org.apache.activemq.broker.TransportConnection - remove connection id:
ID:Berlin-60845-1373442523293-2:1
7929 [ActiveMQ Transport: tcp:///127.0.0.1:60846@5672] DEBUG
org.apache.activemq.transport.tcp.TcpTransport - Stopping transport
tcp:///127.0.0.1:60846@5672
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
