Return-Path: X-Original-To: apmail-activemq-dev-archive@www.apache.org Delivered-To: apmail-activemq-dev-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 81A7F10C14 for ; Mon, 15 Jul 2013 12:56:51 +0000 (UTC) Received: (qmail 86378 invoked by uid 500); 15 Jul 2013 12:56:51 -0000 Delivered-To: apmail-activemq-dev-archive@activemq.apache.org Received: (qmail 86342 invoked by uid 500); 15 Jul 2013 12:56:51 -0000 Mailing-List: contact dev-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@activemq.apache.org Delivered-To: mailing list dev@activemq.apache.org Received: (qmail 86028 invoked by uid 99); 15 Jul 2013 12:56:49 -0000 Received: from arcas.apache.org (HELO arcas.apache.org) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 15 Jul 2013 12:56:49 +0000 Date: Mon, 15 Jul 2013 12:56:49 +0000 (UTC) From: "Axel Podehl (JIRA)" To: dev@activemq.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Closed] (AMQ-4626) AMQP broker prints producer's connection id to stdout MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 [ https://issues.apache.org/jira/browse/AMQ-4626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Axel Podehl closed AMQ-4626. ---------------------------- Resolution: Fixed Fix Version/s: 5.9.0 don't see this anymore with the latest 5.9 snapshot from 20130711 Thanks. > 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 > Fix For: 5.9.0 > > > 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