Merge pull request #55 from nats-io/long-exception-fixes-#30

Long exception fixes #30

Author: Larry McQueary

src/main/java/io/nats/client/ConnectionImpl.java

@@ -172,8 +172,7 @@ class ConnectionImpl implements Connection {
     private Channel<Boolean> fch = new Channel<Boolean>(FLUSH_CHAN_SIZE);
     private List<Thread> threads = new ArrayList<Thread>();
 
-    ConnectionImpl() {
-    }
+    ConnectionImpl() {}
 
     ConnectionImpl(Options opts) {
         this(opts, null);
@@ -505,6 +504,7 @@ public void run() {
                 }
                 if (opts.getClosedCallback() != null) {
                     cbexec.execute(new Runnable() {
+
                         public void run() {
                             opts.getClosedCallback().onClose(new ConnectionEvent(nc));
                             logger.trace("executed ClosedCB");
@@ -525,7 +525,9 @@ public void run() {
                     while (!cbexec.awaitTermination(5, TimeUnit.SECONDS)) {
                         logger.debug("Awaiting completion of threads.");
                     }
-                } catch (InterruptedException e) {
+                } catch (
+
+                InterruptedException e) {
                     logger.debug("Interrupted waiting to shutdown cbexec", e);
                 }
             }
@@ -894,6 +896,7 @@ public void run() {
                 // TODO This mirrors go, and so does not spawn a thread/task.
                 logger.trace("Spawning reconnectedCB from doReconnect()");
                 cbexec.execute(new Runnable() {
+
                     public void run() {
                         opts.getReconnectedCallback().onReconnect(new ConnectionEvent(nc));
 
@@ -909,7 +912,9 @@ public void run() {
             // the lock seems important
             try {
                 flush();
-            } catch (Exception e) {
+            } catch (
+
+            Exception e) {
                 /* NOOP */
             }
             logger.trace("doReconnect reconnected successfully!");
@@ -1183,7 +1188,7 @@ public void run() {
     }
 
     protected Thread go(final Runnable task, final String name, final String group,
-                        final Phaser ph) {
+            final Phaser ph) {
         NATSThread.setDebug(true);
         NATSThread t = new NATSThread(task, name) {
             public void run() {
@@ -1261,7 +1266,7 @@ class ConnectInfo {
         private String version = ConnectionImpl.this.version;
 
         public ConnectInfo(boolean verbose, boolean pedantic, String username, String password,
-                           String token, boolean secure, String connectionName) {
+                String token, boolean secure, String connectionName) {
             this.verbose = new Boolean(verbose);
             this.pedantic = new Boolean(pedantic);
             this.user = username;
@@ -1965,7 +1970,7 @@ private void writePublishProto(ByteBuffer buffer, byte[] subject, byte[] reply,
     }
 
     // Used for handrolled itoa
-    static final byte[] digits = {'0', '1', '2', '3', '4', '5', '6', '7', '8', '9'};
+    static final byte[] digits = { '0', '1', '2', '3', '4', '5', '6', '7', '8', '9' };
 
     void _publish(byte[] subject, byte[] reply, byte[] data) throws IOException {
         int msgSize = (data != null) ? data.length : 0;

src/main/java/io/nats/client/Parser.java

@@ -205,6 +205,7 @@ protected void parse(byte[] buf, int len) throws ParseException {
                             // what is left we fall out and process split
                             // buffer.
                             i = ps.as + ps.ma.size - 1;
+
                             break;
                         default:
                             // We have a leftover argBuf we'll continuing filling