Throw UnsupportedOperationException for unsupported ForkChannel.conne…

…ct() methods

src/org/jgroups/fork/ForkChannel.java

@@ -167,13 +167,23 @@ public ForkChannel connect(String cluster_name) throws Exception {
         return this;
     }
 
+    @Override
+    public ForkChannel connect(String cluster_name, boolean useFlushIfPresent) throws Exception {
+        throw new UnsupportedOperationException();
+    }
+
     @Override
     public ForkChannel connect(String cluster_name, Address target, long timeout) throws Exception {
         connect(cluster_name);
         main_channel.getState(target, timeout);
         return this;
     }
 
+    @Override
+    public ForkChannel connect(String cluster_name, Address target, long timeout, boolean useFlushIfPresent) throws Exception {
+        throw new UnsupportedOperationException();
+    }
+
     /** Removes the fork-channel from the fork-stack's hashmap and resets its state. Does <em>not</em> affect the
      * main-channel */
     @Override
@@ -189,8 +199,7 @@ public ForkChannel disconnect() {
         return this;
     }
 
-    /** Closes the fork-channel, essentially setting its state to CLOSED. Note that - contrary to a regular channel -
-     * a closed fork-channel can be connected again: this means re-attaching the fork-channel to the main-channel*/
+    /** Closes the fork-channel, essentially setting its state to CLOSED */
     @Override
     public void close() {
         ((ForkProtocolStack)prot_stack).remove(fork_channel_id);
@@ -263,7 +272,6 @@ protected ForkChannel setLocalAddress(Address local_addr) {
         return this;
     }
 
-
     /**
      * Creates a new FORK protocol, or returns the existing one, or throws an exception. Never returns null.
      */
@@ -281,8 +289,6 @@ protected static FORK getFORK(JChannel ch, ProtocolStack.Position position, Clas
         return fork;
     }
 
-
-
     protected void setHeader(Message msg) {
         FORK.ForkHeader hdr=msg.getHeader(FORK.ID);
         if(hdr != null)
@@ -291,7 +297,6 @@ protected void setHeader(Message msg) {
             msg.putHeader(FORK.ID, new FORK.ForkHeader(null, fork_channel_id));
     }
 
-
     /** Copies state from main-channel to this fork-channel */
     protected void copyFields() {
         for(Field field: copied_fields) {