[hornetq-commits] JBoss hornetq SVN: r10642 - trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl.
do-not-reply at jboss.org
do-not-reply at jboss.org
Thu May 12 09:01:53 EDT 2011
Author: borges
Date: 2011-05-12 09:01:53 -0400 (Thu, 12 May 2011)
New Revision: 10642
Modified:
trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientLargeMessageImpl.java
trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientSessionFactoryImpl.java
Log:
Fix loads of silly warnings
Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientLargeMessageImpl.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientLargeMessageImpl.java 2011-05-12 12:05:27 UTC (rev 10641)
+++ trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientLargeMessageImpl.java 2011-05-12 13:01:53 UTC (rev 10642)
@@ -27,8 +27,6 @@
* until the buffer is filled up or the user set a streaming.
*
* @author clebertsuconic
- *
- *
*/
public class ClientLargeMessageImpl extends ClientMessageImpl implements ClientLargeMessageInternal
{
@@ -49,6 +47,7 @@
/**
* @return the largeMessageSize
*/
+ @Override
public long getLargeMessageSize()
{
return largeMessageSize;
@@ -57,6 +56,7 @@
/**
* @param largeMessageSize the largeMessageSize to set
*/
+ @Override
public void setLargeMessageSize(long largeMessageSize)
{
this.largeMessageSize = largeMessageSize;
@@ -70,6 +70,7 @@
// Public --------------------------------------------------------
+ @Override
public int getEncodeSize()
{
if (bodyBuffer != null)
@@ -85,16 +86,19 @@
/**
* @return the largeMessage
*/
+ @Override
public boolean isLargeMessage()
{
return true;
}
+ @Override
public void setLargeMessageController(final LargeMessageController controller)
{
largeMessageController = controller;
}
+ @Override
public HornetQBuffer getBodyBuffer()
{
checkBuffer();
@@ -102,11 +106,13 @@
return bodyBuffer;
}
+ @Override
public int getBodySize()
{
return getLongProperty(Message.HDR_LARGE_BODY_SIZE).intValue();
}
+ @Override
public LargeMessageController getLargeMessageController()
{
return largeMessageController;
@@ -115,6 +121,7 @@
/* (non-Javadoc)
* @see org.hornetq.api.core.client.ClientMessage#saveToOutputStream(java.io.OutputStream)
*/
+ @Override
public void saveToOutputStream(final OutputStream out) throws HornetQException
{
if (bodyBuffer != null)
@@ -131,6 +138,7 @@
/* (non-Javadoc)
* @see org.hornetq.api.core.client.ClientMessage#setOutputStream(java.io.OutputStream)
*/
+ @Override
public void setOutputStream(final OutputStream out) throws HornetQException
{
if (bodyBuffer != null)
@@ -146,6 +154,7 @@
/* (non-Javadoc)
* @see org.hornetq.api.core.client.ClientMessage#waitOutputStreamCompletion()
*/
+ @Override
public boolean waitOutputStreamCompletion(final long timeMilliseconds) throws HornetQException
{
if (bodyBuffer != null)
@@ -158,6 +167,7 @@
}
}
+ @Override
public void discardBody()
{
if (bodyBuffer != null)
Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientSessionFactoryImpl.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientSessionFactoryImpl.java 2011-05-12 12:05:27 UTC (rev 10641)
+++ trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientSessionFactoryImpl.java 2011-05-12 13:01:53 UTC (rev 10642)
@@ -17,7 +17,6 @@
import java.security.AccessController;
import java.security.PrivilegedAction;
import java.util.ArrayList;
-import java.util.Collection;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
@@ -29,9 +28,12 @@
import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.Lock;
-import org.hornetq.api.core.*;
+import org.hornetq.api.core.HornetQBuffer;
+import org.hornetq.api.core.HornetQException;
+import org.hornetq.api.core.Interceptor;
+import org.hornetq.api.core.SimpleString;
+import org.hornetq.api.core.TransportConfiguration;
import org.hornetq.api.core.client.ClientSession;
-import org.hornetq.api.core.client.HornetQClient;
import org.hornetq.api.core.client.ServerLocator;
import org.hornetq.api.core.client.SessionFailureListener;
import org.hornetq.core.logging.Logger;
@@ -203,6 +205,7 @@
}
+ @Override
public void connect(int initialConnectAttempts, boolean failoverOnInitialConnection) throws HornetQException
{
// Get the connection
@@ -221,11 +224,13 @@
}
+ @Override
public TransportConfiguration getConnectorConfiguration()
{
return connectorConfig;
}
+ @Override
public void setBackupConnector(TransportConfiguration live, TransportConfiguration backUp)
{
if(live.equals(connectorConfig) && backUp != null)
@@ -234,11 +239,13 @@
}
}
+ @Override
public Object getBackupConnector()
{
return backupConfig;
}
+ @Override
public ClientSession createSession(final String username,
final String password,
final boolean xa,
@@ -256,6 +263,7 @@
ackBatchSize);
}
+ @Override
public ClientSession createSession(final boolean autoCommitSends,
final boolean autoCommitAcks,
final int ackBatchSize) throws HornetQException
@@ -269,6 +277,7 @@
ackBatchSize);
}
+ @Override
public ClientSession createXASession() throws HornetQException
{
return createSessionInternal(null,
@@ -280,6 +289,7 @@
serverLocator.getAckBatchSize());
}
+ @Override
public ClientSession createTransactedSession() throws HornetQException
{
return createSessionInternal(null,
@@ -291,6 +301,7 @@
serverLocator.getAckBatchSize());
}
+ @Override
public ClientSession createSession() throws HornetQException
{
return createSessionInternal(null,
@@ -302,6 +313,7 @@
serverLocator.getAckBatchSize());
}
+ @Override
public ClientSession createSession(final boolean autoCommitSends, final boolean autoCommitAcks) throws HornetQException
{
return createSessionInternal(null,
@@ -313,6 +325,7 @@
serverLocator.getAckBatchSize());
}
+ @Override
public ClientSession createSession(final boolean xa, final boolean autoCommitSends, final boolean autoCommitAcks) throws HornetQException
{
return createSessionInternal(null,
@@ -324,6 +337,7 @@
serverLocator.getAckBatchSize());
}
+ @Override
public ClientSession createSession(final boolean xa,
final boolean autoCommitSends,
final boolean autoCommitAcks,
@@ -340,16 +354,19 @@
// ConnectionLifeCycleListener implementation --------------------------------------------------
+ @Override
public void connectionCreated(final Connection connection, final ProtocolType protocol)
{
}
+ @Override
public void connectionDestroyed(final Object connectionID)
{
handleConnectionFailure(connectionID,
new HornetQException(HornetQException.NOT_CONNECTED, "Channel disconnected"));
}
+ @Override
public void connectionException(final Object connectionID, final HornetQException me)
{
handleConnectionFailure(connectionID, me);
@@ -357,6 +374,7 @@
// Must be synchronized to prevent it happening concurrently with failover which can lead to
// inconsistencies
+ @Override
public void removeSession(final ClientSessionInternal session, boolean failingOver)
{
synchronized (sessions)
@@ -365,30 +383,36 @@
}
}
+ @Override
public void connectionReadyForWrites(final Object connectionID, final boolean ready)
{
}
+ @Override
public synchronized int numConnections()
{
return connection != null ? 1 : 0;
}
+ @Override
public int numSessions()
{
return sessions.size();
}
+ @Override
public void addFailureListener(final SessionFailureListener listener)
{
listeners.add(listener);
}
+ @Override
public boolean removeFailureListener(final SessionFailureListener listener)
{
return listeners.remove(listener);
}
+ @Override
public void causeExit()
{
exitLoop = true;
@@ -398,6 +422,7 @@
}
}
+ @Override
public void close()
{
if (closed)
@@ -436,6 +461,7 @@
closed = true;
}
+ @Override
public ServerLocator getServerLocator()
{
return serverLocator;
@@ -968,6 +994,7 @@
}
}
+ @Override
public CoreRemotingConnection getConnection()
{
if (connection == null)
@@ -1128,6 +1155,7 @@
return connection;
}
+ @Override
public void finalize() throws Throwable
{
if (!closed)
@@ -1147,6 +1175,7 @@
{
return AccessController.doPrivileged(new PrivilegedAction<ConnectorFactory>()
{
+ @Override
public ConnectorFactory run()
{
ClassLoader loader = Thread.currentThread().getContextClassLoader();
@@ -1212,6 +1241,7 @@
this.conn = conn;
}
+ @Override
public void handlePacket(final Packet packet)
{
final byte type = packet.getType();
@@ -1224,6 +1254,7 @@
{
// Must be executed on new thread since cannot block the netty thread for a long time and fail can
// cause reconnect loop
+ @Override
public void run()
{
SimpleString nodeID = msg.getNodeID();
@@ -1258,6 +1289,7 @@
private class DelegatingBufferHandler implements BufferHandler
{
+ @Override
public void bufferReceived(final Object connectionID, final HornetQBuffer buffer)
{
CoreRemotingConnection theConn = connection;
@@ -1278,6 +1310,7 @@
this.connectionID = connectionID;
}
+ @Override
public void connectionFailed(final HornetQException me, boolean failedOver)
{
handleConnectionFailure(connectionID, me);
@@ -1293,6 +1326,7 @@
pingRunnable = new WeakReference<PingRunnable>(runnable);
}
+ @Override
public void run()
{
PingRunnable runnable = pingRunnable.get();
@@ -1313,6 +1347,7 @@
private long lastCheck = System.currentTimeMillis();
+ @Override
public synchronized void run()
{
if (cancelled || stopPingingAfterOne && !first)
@@ -1336,6 +1371,7 @@
threadPool.execute(new Runnable()
{
// Must be executed on different thread
+ @Override
public void run()
{
connection.fail(me);
More information about the hornetq-commits
mailing list