diff options
| author | Martin Ritchie <ritchiem@apache.org> | 2006-12-13 13:33:52 +0000 |
|---|---|---|
| committer | Martin Ritchie <ritchiem@apache.org> | 2006-12-13 13:33:52 +0000 |
| commit | 20895e186e34cbcff712243b1c68e750d5de3152 (patch) | |
| tree | 28d9d684fe177d61ac8bb6d293f457b426a87e96 /java | |
| parent | f0cfd61e5dceb847df25e72121bb6c6659906932 (diff) | |
| download | qpid-python-20895e186e34cbcff712243b1c68e750d5de3152.tar.gz | |
Minor white space and logging changes
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@486646 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java')
3 files changed, 8 insertions, 7 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/state/StateWaiter.java b/java/client/src/main/java/org/apache/qpid/client/state/StateWaiter.java index 42ae5a7b17..18e1fdad82 100644 --- a/java/client/src/main/java/org/apache/qpid/client/state/StateWaiter.java +++ b/java/client/src/main/java/org/apache/qpid/client/state/StateWaiter.java @@ -46,7 +46,7 @@ public class StateWaiter implements StateListener public void waituntilStateHasChanged() throws AMQException { - synchronized (_monitor) + synchronized(_monitor) { // // The guard is required in case we are woken up by a spurious @@ -71,22 +71,22 @@ public class StateWaiter implements StateListener _logger.debug("Throwable reached state waiter: " + _throwable); if (_throwable instanceof AMQException) { - throw (AMQException) _throwable; + throw(AMQException) _throwable; } else { - throw new AMQException("Error: " + _throwable, _throwable); // FIXME: this will wrap FailoverException in throwable which will prevent it being caught. + throw new AMQException("Error: " + _throwable, _throwable); // FIXME: this will wrap FailoverException in throwable which will prevent it being caught. } } } public void stateChanged(AMQState oldState, AMQState newState) { - synchronized (_monitor) + synchronized(_monitor) { if (_logger.isDebugEnabled()) { - _logger.debug("stateChanged called"); + _logger.debug("stateChanged called changing from :" + oldState + " to :" + newState); } if (_state == newState) { @@ -103,7 +103,7 @@ public class StateWaiter implements StateListener public void error(Throwable t) { - synchronized (_monitor) + synchronized(_monitor) { if (_logger.isDebugEnabled()) { diff --git a/java/client/src/main/java/org/apache/qpid/client/transport/SocketTransportConnection.java b/java/client/src/main/java/org/apache/qpid/client/transport/SocketTransportConnection.java index 78d937f453..2e47ed2666 100644 --- a/java/client/src/main/java/org/apache/qpid/client/transport/SocketTransportConnection.java +++ b/java/client/src/main/java/org/apache/qpid/client/transport/SocketTransportConnection.java @@ -60,6 +60,7 @@ public class SocketTransportConnection implements ITransportConnection // once more testing of the performance of the simple allocator has been done if (!Boolean.getBoolean("amqj.enablePooledAllocator")) { + _logger.warn("Using SimpleByteBufferAllocator"); ByteBuffer.setAllocator(new SimpleByteBufferAllocator()); } diff --git a/java/client/src/main/java/org/apache/qpid/client/transport/TransportConnection.java b/java/client/src/main/java/org/apache/qpid/client/transport/TransportConnection.java index 58507a75ca..e9e23aefdb 100644 --- a/java/client/src/main/java/org/apache/qpid/client/transport/TransportConnection.java +++ b/java/client/src/main/java/org/apache/qpid/client/transport/TransportConnection.java @@ -268,7 +268,7 @@ public class TransportConnection Object[] params = {port}; provider = (IoHandlerAdapter) Class.forName(protocolProviderClass).getConstructor(cnstr).newInstance(params); //Give the broker a second to create - _logger.info("Created Instance"); + _logger.info("Created VMBroker Instance:" + port); } catch (Exception e) { |