Remove unnecessary casts

examples/jms/instantiate-connection-factory/src/main/java/org/hornetq/jms/example/InstantiateConnectionFactoryExample.java

@@ -66,7 +66,7 @@ public boolean runExample() throws Exception
                                                                                     connectionParams);
 
          // Step 3 Directly instantiate the JMS ConnectionFactory object using that TransportConfiguration
-         ConnectionFactory cf = (ConnectionFactory)HornetQJMSClient.createConnectionFactoryWithoutHA(JMSFactoryType.CF, transportConfiguration);
+         ConnectionFactory cf = HornetQJMSClient.createConnectionFactoryWithoutHA(JMSFactoryType.CF, transportConfiguration);
 
          // Step 4.Create a JMS Connection
          connection = cf.createConnection();

examples/jms/symmetric-cluster/src/main/java/org/hornetq/jms/example/SymmetricClusterExample.java

@@ -81,7 +81,7 @@ public boolean runExample() throws Exception
          UDPBroadcastGroupConfiguration udpCfg = new UDPBroadcastGroupConfiguration("231.7.7.7", 9876, null, -1);
          DiscoveryGroupConfiguration groupConfiguration = new DiscoveryGroupConfiguration(HornetQClient.DEFAULT_DISCOVERY_INITIAL_WAIT_TIMEOUT, HornetQClient.DEFAULT_DISCOVERY_INITIAL_WAIT_TIMEOUT, udpCfg);
 
-         ConnectionFactory cf = (ConnectionFactory)HornetQJMSClient.createConnectionFactoryWithHA(groupConfiguration, JMSFactoryType.CF);
+         ConnectionFactory cf = HornetQJMSClient.createConnectionFactoryWithHA(groupConfiguration, JMSFactoryType.CF);
 
          // We give a little while for each server to broadcast its whereabouts to the client
          Thread.sleep(2000);

hornetq-core-client/src/main/java/org/hornetq/utils/HornetQBufferInputStream.java

@@ -122,7 +122,7 @@ public long skip(final long len) throws IOException
 
       int size = Math.min(remainingBytes(), (int) len);
 
-      bb.skipBytes((int)size);
+      bb.skipBytes(size);
 
       return size;
    }

hornetq-rest/src/test/java/org/hornetq/rest/test/JMSTest.java

@@ -271,7 +271,7 @@ public void testJmsProducer() throws Exception
          ClientResponse<?> res = consumeNext.request().header("Accept-Wait", "2").accept("application/json").post(String.class);
          Assert.assertEquals(200, res.getStatus());
          Assert.assertEquals("application/json", res.getHeaders().getFirst("Content-Type").toString().toLowerCase());
-         Order order2 = (Order) res.getEntity(Order.class);
+         Order order2 = res.getEntity(Order.class);
          res.releaseConnection();
          Assert.assertEquals(order, order2);
          consumeNext = MessageTestBase.getLinkByTitle(manager.getQueueManager().getLinkStrategy(), res, "consume-next");
@@ -288,7 +288,7 @@ public void testJmsProducer() throws Exception
          ClientResponse<?> res = consumeNext.request().header("Accept-Wait", "2").post(String.class);
          Assert.assertEquals(200, res.getStatus());
          Assert.assertEquals("application/xml", res.getHeaders().getFirst("Content-Type").toString().toLowerCase());
-         Order order2 = (Order) res.getEntity(Order.class);
+         Order order2 = res.getEntity(Order.class);
          res.releaseConnection();
          Assert.assertEquals(order, order2);
          consumeNext = MessageTestBase.getLinkByTitle(manager.getQueueManager().getLinkStrategy(), res, "consume-next");

hornetq-rest/src/test/java/org/hornetq/rest/test/SelectorTest.java

@@ -325,7 +325,7 @@ private Link consumeOrder(Order order, Link consumeNext)
       ClientResponse<?> response = consumeNext.request().header("Accept-Wait", "4").accept("application/xml").post(String.class);
       Assert.assertEquals(200, response.getStatus());
       Assert.assertEquals("application/xml", response.getHeaders().getFirst("Content-Type").toString().toLowerCase());
-      Order order2 = (Order) response.getEntity(Order.class);
+      Order order2 = response.getEntity(Order.class);
       Assert.assertEquals(order, order2);
       consumeNext = MessageTestBase.getLinkByTitle(manager.getQueueManager().getLinkStrategy(), response, "consume-next");
       Assert.assertNotNull(consumeNext);

hornetq-rest/src/test/java/org/hornetq/rest/test/TransformTest.java

@@ -151,7 +151,7 @@ public void testTransform() throws Exception
          response = consumeNext.request().accept("application/xml").post(String.class);
          Assert.assertEquals(200, response.getStatus());
          Assert.assertEquals("application/xml", response.getHeaders().getFirst("Content-Type").toString().toLowerCase());
-         Order order2 = (Order) response.getEntity(Order.class);
+         Order order2 = response.getEntity(Order.class);
          response.releaseConnection();
          Assert.assertEquals(order, order2);
          consumeNext = MessageTestBase.getLinkByTitle(manager.getQueueManager().getLinkStrategy(), response, "consume-next");
@@ -168,7 +168,7 @@ public void testTransform() throws Exception
          response = consumeNext.request().accept("application/json").post(String.class);
          Assert.assertEquals(200, response.getStatus());
          Assert.assertEquals("application/json", response.getHeaders().getFirst("Content-Type").toString().toLowerCase());
-         Order order2 = (Order) response.getEntity(Order.class);
+         Order order2 = response.getEntity(Order.class);
          response.releaseConnection();
          Assert.assertEquals(order, order2);
          consumeNext = MessageTestBase.getLinkByTitle(manager.getQueueManager().getLinkStrategy(), response, "consume-next");
@@ -185,7 +185,7 @@ public void testTransform() throws Exception
          response = consumeNext.request().post(String.class);
          Assert.assertEquals(200, response.getStatus());
          Assert.assertEquals("application/xml", response.getHeaders().getFirst("Content-Type").toString().toLowerCase());
-         Order order2 = (Order) response.getEntity(Order.class);
+         Order order2 = response.getEntity(Order.class);
          response.releaseConnection();
          Assert.assertEquals(order, order2);
          consumeNext = MessageTestBase.getLinkByTitle(manager.getQueueManager().getLinkStrategy(), response, "consume-next");

hornetq-server/src/main/java/org/hornetq/core/persistence/impl/journal/DescribeJournal.java

@@ -222,7 +222,7 @@ else if (info.getUserRecordType() == JournalRecordIds.PAGE_CURSOR_COUNTER_INC)
 
                   PageSubscriptionCounterImpl subsCounter = lookupCounter(counters, queueIDForCounter);
 
-                  subsCounter.loadInc(info.id, (int)encoding.value);
+                  subsCounter.loadInc(info.id, encoding.value);
                   subsCounter.processReload();
                   out.print("#Counter queue " + queueIDForCounter + " value=" + subsCounter.getValue() + " increased by " + encoding.value);
                   if (subsCounter.getValue() < 0)
@@ -335,7 +335,7 @@ else if (info.getUserRecordType() == JournalRecordIds.PAGE_CURSOR_COUNTER_INC)
 
             subsCounter = lookupCounter(counters, queueIDForCounter);
 
-            subsCounter.loadInc(info.id, (int)encoding.value);
+            subsCounter.loadInc(info.id, encoding.value);
             subsCounter.processReload();
          }
 

tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/bridge/BridgeTest.java

@@ -1514,7 +1514,7 @@ public void testBridgeWithPaging() throws Exception
 
          for (int i = 0; i < numMessages; i++)
          {
-            AtomicInteger msgCount = receivedMsg.get((Integer) i);
+            AtomicInteger msgCount = receivedMsg.get(Integer.valueOf(i));
             if (msgCount == null)
             {
                System.err.println("Msg " + i + " wasn't received");

tests/integration-tests/src/test/java/org/hornetq/tests/integration/jms/bridge/BridgeTestBase.java

@@ -237,7 +237,7 @@ public ConnectionFactory createConnectionFactory() throws Exception
             cf.setCacheLargeMessagesClient(true);
             cf.setProducerWindowSize(100);
 
-            return (ConnectionFactory) cf;
+            return cf;
          }
 
       };
@@ -257,7 +257,7 @@ public ConnectionFactory createConnectionFactory() throws Exception
             cf.setBlockOnDurableSend(true);
             cf.setCacheLargeMessagesClient(true);
 
-            return (ConnectionFactory) cf;
+            return cf;
          }
 
       };

tests/integration-tests/src/test/java/org/hornetq/tests/integration/jms/bridge/ClusteredBridgeTestBase.java

@@ -221,7 +221,7 @@ public ConnectionFactory createConnectionFactory() throws Exception
                HornetQConnectionFactory cf = HornetQJMSClient.createConnectionFactoryWithHA(JMSFactoryType.XA_CF,
                                                                                             liveConnector);
                cf.getServerLocator().setReconnectAttempts(-1);
-               return (ConnectionFactory) cf;
+               return cf;
             }
          };
 

tests/integration-tests/src/test/java/org/hornetq/tests/integration/jms/cluster/MultipleThreadsOpeningTest.java

@@ -13,7 +13,6 @@
 package org.hornetq.tests.integration.jms.cluster;
 
 import javax.jms.Connection;
-import javax.jms.ConnectionFactory;
 import javax.jms.Session;
 import java.util.concurrent.CountDownLatch;
 
@@ -35,7 +34,7 @@ public class MultipleThreadsOpeningTest extends JMSClusteredTestBase
    @Test
    public void testMultipleOpen() throws Exception
    {
-      cf1 = (ConnectionFactory) HornetQJMSClient.createConnectionFactoryWithHA(JMSFactoryType.CF, new TransportConfiguration(InVMConnectorFactory.class.getName(),
+      cf1 = HornetQJMSClient.createConnectionFactoryWithHA(JMSFactoryType.CF, new TransportConfiguration(InVMConnectorFactory.class.getName(),
                                                                                                                              generateInVMParams(0)));
 
       final int numberOfOpens = 2000;

tests/integration-tests/src/test/java/org/hornetq/tests/integration/jms/consumer/ConsumerTest.java

@@ -13,7 +13,6 @@
 package org.hornetq.tests.integration.jms.consumer;
 
 import javax.jms.Connection;
-import javax.jms.ConnectionFactory;
 import javax.jms.JMSConsumer;
 import javax.jms.JMSContext;
 import javax.jms.JMSException;
@@ -75,7 +74,7 @@ public void setUp() throws Exception
       jmsServer.createQueue(false, ConsumerTest.Q_NAME, null, true, ConsumerTest.Q_NAME);
       jmsServer.createTopic(true, T_NAME, "/topic/" + T_NAME);
       jmsServer.createTopic(true, T2_NAME, "/topic/" + T2_NAME);
-      cf = (ConnectionFactory) HornetQJMSClient.createConnectionFactoryWithoutHA(JMSFactoryType.CF, new TransportConfiguration("org.hornetq.core.remoting.impl.invm.InVMConnectorFactory"));
+      cf = HornetQJMSClient.createConnectionFactoryWithoutHA(JMSFactoryType.CF, new TransportConfiguration("org.hornetq.core.remoting.impl.invm.InVMConnectorFactory"));
    }
 
    @Override

tests/integration-tests/src/test/java/org/hornetq/tests/integration/jms/jms2client/JmsContextTest.java

@@ -573,14 +573,14 @@ public void bytesMessage() throws Exception
          BytesMessage bMsg = context.createBytesMessage();
          bMsg.setStringProperty("COM_SUN_JMS_TESTNAME", "sendAndRecvMsgOfEachTypeCLTest");
          bMsg.writeByte((byte) 1);
-         bMsg.writeInt((int) 22);
+         bMsg.writeInt(22);
          CountDownLatch latch = new CountDownLatch(1);
          SimpleCompletionListener listener = new SimpleCompletionListener(latch);
          producer.setAsync(listener);
          producer.send(queue1, bMsg);
          assertTrue(latch.await(5, TimeUnit.SECONDS));
          assertEquals(listener.message.readByte(), (byte) 1);
-         assertEquals(listener.message.readInt(), (int) 22);
+         assertEquals(listener.message.readInt(), 22);
       }
       finally
       {

tests/integration-tests/src/test/java/org/hornetq/tests/integration/management/BridgeControlUsingCoreTest.java

@@ -75,13 +75,13 @@ public void testAttributes() throws Exception
       checkResource(ObjectNameBuilder.DEFAULT.getBridgeObjectName(bridgeConfig.getName()));
       CoreMessagingProxy proxy = createProxy(bridgeConfig.getName());
 
-      Assert.assertEquals(bridgeConfig.getName(), (String)proxy.retrieveAttributeValue("name"));
+      Assert.assertEquals(bridgeConfig.getName(), proxy.retrieveAttributeValue("name"));
       Assert.assertEquals(bridgeConfig.getDiscoveryGroupName(),
-                          (String)proxy.retrieveAttributeValue("discoveryGroupName"));
-      Assert.assertEquals(bridgeConfig.getQueueName(), (String)proxy.retrieveAttributeValue("queueName"));
+                          proxy.retrieveAttributeValue("discoveryGroupName"));
+      Assert.assertEquals(bridgeConfig.getQueueName(), proxy.retrieveAttributeValue("queueName"));
       Assert.assertEquals(bridgeConfig.getForwardingAddress(),
-                          (String)proxy.retrieveAttributeValue("forwardingAddress"));
-      Assert.assertEquals(bridgeConfig.getFilterString(), (String)proxy.retrieveAttributeValue("filterString"));
+                          proxy.retrieveAttributeValue("forwardingAddress"));
+      Assert.assertEquals(bridgeConfig.getFilterString(), proxy.retrieveAttributeValue("filterString"));
       Assert.assertEquals(bridgeConfig.getRetryInterval(),
                           ((Long)proxy.retrieveAttributeValue("retryInterval")).longValue());
       Assert.assertEquals(bridgeConfig.getRetryIntervalMultiplier(),

tests/integration-tests/src/test/java/org/hornetq/tests/util/JMSClusteredTestBase.java

@@ -127,9 +127,9 @@ public void setUp() throws Exception
 
       waitForTopology(jmsServer2.getHornetQServer(), 2);
 
-      cf1 = (ConnectionFactory) HornetQJMSClient.createConnectionFactoryWithoutHA(JMSFactoryType.CF, new TransportConfiguration(InVMConnectorFactory.class.getName(),
+      cf1 = HornetQJMSClient.createConnectionFactoryWithoutHA(JMSFactoryType.CF, new TransportConfiguration(InVMConnectorFactory.class.getName(),
                                                                                                                                 generateInVMParams(0)));
-      cf2 = (ConnectionFactory) HornetQJMSClient.createConnectionFactoryWithoutHA(JMSFactoryType.CF, new TransportConfiguration(InVMConnectorFactory.class.getName(),
+      cf2 = HornetQJMSClient.createConnectionFactoryWithoutHA(JMSFactoryType.CF, new TransportConfiguration(InVMConnectorFactory.class.getName(),
                                                                                                                                 generateInVMParams(1)));
    }
 

tests/timing-tests/src/test/java/org/hornetq/tests/timing/jms/bridge/impl/JMSBridgeImplTest.java

@@ -472,7 +472,7 @@ public void doTestAutoAckOnSource(int maxBatchSize) throws Exception
 
       sourceConn.close();
 
-      JMSQueueControl jmsQueueControl = (JMSQueueControl) MBeanServerInvocationHandler.newProxyInstance(
+      JMSQueueControl jmsQueueControl = MBeanServerInvocationHandler.newProxyInstance(
          ManagementFactory.getPlatformMBeanServer(),
          ObjectNameBuilder.DEFAULT.getJMSQueueObjectName(JMSBridgeImplTest.SOURCE),
          JMSQueueControl.class,