Skip to main content
aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorEike Stepper2008-11-04 09:58:14 +0000
committerEike Stepper2008-11-04 09:58:14 +0000
commit29d2ec870a4666f4ddfba4bcd0727aa60953eafc (patch)
tree58ca1d644294f6c2fb41b6ed6a19a96dd553dea0 /plugins/org.eclipse.net4j.jms
parentaac49607637484bcd3de42fa09393b2f896caa10 (diff)
downloadcdo-29d2ec870a4666f4ddfba4bcd0727aa60953eafc.tar.gz
cdo-29d2ec870a4666f4ddfba4bcd0727aa60953eafc.tar.xz
cdo-29d2ec870a4666f4ddfba4bcd0727aa60953eafc.zip
[252221] Provide proper RemoteException for signals
https://bugs.eclipse.org/bugs/show_bug.cgi?id=252221
Diffstat (limited to 'plugins/org.eclipse.net4j.jms')
-rw-r--r--plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSAcknowledgeRequest.java3
-rw-r--r--plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSClientMessageRequest.java5
-rw-r--r--plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSCloseSessionRequest.java5
-rw-r--r--plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSCommitRequest.java5
-rw-r--r--plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSDeregisterConsumerRequest.java5
-rw-r--r--plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSLogoffRequest.java3
-rw-r--r--plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSLogonRequest.java5
-rw-r--r--plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSOpenSessionRequest.java5
-rw-r--r--plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSRecoverRequest.java5
-rw-r--r--plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSRegisterConsumerRequest.java5
-rw-r--r--plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSRollbackRequest.java5
-rw-r--r--plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSServerMessageIndication.java3
-rw-r--r--plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSSyncRequest.java5
13 files changed, 23 insertions, 36 deletions
diff --git a/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSAcknowledgeRequest.java b/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSAcknowledgeRequest.java
index a0bb721ea9..cbb306c22f 100644
--- a/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSAcknowledgeRequest.java
+++ b/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSAcknowledgeRequest.java
@@ -14,7 +14,6 @@ import org.eclipse.net4j.jms.JMSProtocolConstants;
import org.eclipse.net4j.signal.Request;
import org.eclipse.net4j.util.io.ExtendedDataOutputStream;
-import java.io.IOException;
/**
* @author Eike Stepper
@@ -33,7 +32,7 @@ public class JMSAcknowledgeRequest extends Request
}
@Override
- protected void requesting(ExtendedDataOutputStream out) throws IOException
+ protected void requesting(ExtendedDataOutputStream out) throws Exception
{
out.writeInt(sessionID);
}
diff --git a/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSClientMessageRequest.java b/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSClientMessageRequest.java
index 2696ceb83b..bb432e88fc 100644
--- a/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSClientMessageRequest.java
+++ b/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSClientMessageRequest.java
@@ -17,7 +17,6 @@ import org.eclipse.net4j.signal.RequestWithConfirmation;
import org.eclipse.net4j.util.io.ExtendedDataInputStream;
import org.eclipse.net4j.util.io.ExtendedDataOutputStream;
-import java.io.IOException;
/**
* @author Eike Stepper
@@ -36,13 +35,13 @@ public class JMSClientMessageRequest extends RequestWithConfirmation<String>
}
@Override
- protected void requesting(ExtendedDataOutputStream out) throws IOException
+ protected void requesting(ExtendedDataOutputStream out) throws Exception
{
MessageUtil.write(out, message);
}
@Override
- protected String confirming(ExtendedDataInputStream in) throws IOException
+ protected String confirming(ExtendedDataInputStream in) throws Exception
{
return in.readString();
}
diff --git a/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSCloseSessionRequest.java b/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSCloseSessionRequest.java
index 4d3001245e..914a7020d5 100644
--- a/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSCloseSessionRequest.java
+++ b/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSCloseSessionRequest.java
@@ -15,7 +15,6 @@ import org.eclipse.net4j.signal.RequestWithConfirmation;
import org.eclipse.net4j.util.io.ExtendedDataInputStream;
import org.eclipse.net4j.util.io.ExtendedDataOutputStream;
-import java.io.IOException;
/**
* @author Eike Stepper
@@ -34,13 +33,13 @@ public class JMSCloseSessionRequest extends RequestWithConfirmation<Boolean>
}
@Override
- protected void requesting(ExtendedDataOutputStream out) throws IOException
+ protected void requesting(ExtendedDataOutputStream out) throws Exception
{
out.writeInt(sessionID);
}
@Override
- protected Boolean confirming(ExtendedDataInputStream in) throws IOException
+ protected Boolean confirming(ExtendedDataInputStream in) throws Exception
{
return in.readBoolean();
}
diff --git a/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSCommitRequest.java b/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSCommitRequest.java
index d0c41b8a47..3ccc0ff203 100644
--- a/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSCommitRequest.java
+++ b/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSCommitRequest.java
@@ -17,7 +17,6 @@ import org.eclipse.net4j.signal.RequestWithConfirmation;
import org.eclipse.net4j.util.io.ExtendedDataInputStream;
import org.eclipse.net4j.util.io.ExtendedDataOutputStream;
-import java.io.IOException;
import java.util.List;
/**
@@ -40,7 +39,7 @@ public class JMSCommitRequest extends RequestWithConfirmation<String[]>
}
@Override
- protected void requesting(ExtendedDataOutputStream out) throws IOException
+ protected void requesting(ExtendedDataOutputStream out) throws Exception
{
out.writeInt(sessionID);
out.writeInt(messages.size());
@@ -51,7 +50,7 @@ public class JMSCommitRequest extends RequestWithConfirmation<String[]>
}
@Override
- protected String[] confirming(ExtendedDataInputStream in) throws IOException
+ protected String[] confirming(ExtendedDataInputStream in) throws Exception
{
int size = in.readInt();
if (size == -1)
diff --git a/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSDeregisterConsumerRequest.java b/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSDeregisterConsumerRequest.java
index 0684b62ff4..d7f6ca5a59 100644
--- a/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSDeregisterConsumerRequest.java
+++ b/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSDeregisterConsumerRequest.java
@@ -15,7 +15,6 @@ import org.eclipse.net4j.signal.RequestWithConfirmation;
import org.eclipse.net4j.util.io.ExtendedDataInputStream;
import org.eclipse.net4j.util.io.ExtendedDataOutputStream;
-import java.io.IOException;
/**
* @author Eike Stepper
@@ -37,14 +36,14 @@ public class JMSDeregisterConsumerRequest extends RequestWithConfirmation<Boolea
}
@Override
- protected void requesting(ExtendedDataOutputStream out) throws IOException
+ protected void requesting(ExtendedDataOutputStream out) throws Exception
{
out.writeInt(sessionID);
out.writeLong(consumerID);
}
@Override
- protected Boolean confirming(ExtendedDataInputStream in) throws IOException
+ protected Boolean confirming(ExtendedDataInputStream in) throws Exception
{
return in.readBoolean();
}
diff --git a/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSLogoffRequest.java b/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSLogoffRequest.java
index bd4079f7f9..9e1b2ff4fa 100644
--- a/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSLogoffRequest.java
+++ b/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSLogoffRequest.java
@@ -14,7 +14,6 @@ import org.eclipse.net4j.jms.JMSProtocolConstants;
import org.eclipse.net4j.signal.Request;
import org.eclipse.net4j.util.io.ExtendedDataOutputStream;
-import java.io.IOException;
/**
* @author Eike Stepper
@@ -30,7 +29,7 @@ public class JMSLogoffRequest extends Request
}
@Override
- protected void requesting(ExtendedDataOutputStream out) throws IOException
+ protected void requesting(ExtendedDataOutputStream out) throws Exception
{
}
}
diff --git a/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSLogonRequest.java b/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSLogonRequest.java
index 25e34ee40e..7c101ccaea 100644
--- a/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSLogonRequest.java
+++ b/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSLogonRequest.java
@@ -15,7 +15,6 @@ import org.eclipse.net4j.signal.RequestWithConfirmation;
import org.eclipse.net4j.util.io.ExtendedDataInputStream;
import org.eclipse.net4j.util.io.ExtendedDataOutputStream;
-import java.io.IOException;
/**
* @author Eike Stepper
@@ -37,14 +36,14 @@ public class JMSLogonRequest extends RequestWithConfirmation<Boolean>
}
@Override
- protected void requesting(ExtendedDataOutputStream out) throws IOException
+ protected void requesting(ExtendedDataOutputStream out) throws Exception
{
out.writeString(userName);
out.writeString(password);
}
@Override
- protected Boolean confirming(ExtendedDataInputStream in) throws IOException
+ protected Boolean confirming(ExtendedDataInputStream in) throws Exception
{
return in.readBoolean();
}
diff --git a/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSOpenSessionRequest.java b/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSOpenSessionRequest.java
index 31dfb30433..4dcb0f59f3 100644
--- a/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSOpenSessionRequest.java
+++ b/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSOpenSessionRequest.java
@@ -15,7 +15,6 @@ import org.eclipse.net4j.signal.RequestWithConfirmation;
import org.eclipse.net4j.util.io.ExtendedDataInputStream;
import org.eclipse.net4j.util.io.ExtendedDataOutputStream;
-import java.io.IOException;
/**
* @author Eike Stepper
@@ -34,13 +33,13 @@ public class JMSOpenSessionRequest extends RequestWithConfirmation<Boolean>
}
@Override
- protected void requesting(ExtendedDataOutputStream out) throws IOException
+ protected void requesting(ExtendedDataOutputStream out) throws Exception
{
out.writeInt(sessionID);
}
@Override
- protected Boolean confirming(ExtendedDataInputStream in) throws IOException
+ protected Boolean confirming(ExtendedDataInputStream in) throws Exception
{
return in.readBoolean();
}
diff --git a/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSRecoverRequest.java b/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSRecoverRequest.java
index 5d02aae7fe..3b020e4d66 100644
--- a/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSRecoverRequest.java
+++ b/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSRecoverRequest.java
@@ -15,7 +15,6 @@ import org.eclipse.net4j.signal.RequestWithConfirmation;
import org.eclipse.net4j.util.io.ExtendedDataInputStream;
import org.eclipse.net4j.util.io.ExtendedDataOutputStream;
-import java.io.IOException;
/**
* @author Eike Stepper
@@ -34,13 +33,13 @@ public class JMSRecoverRequest extends RequestWithConfirmation<Object>
}
@Override
- protected void requesting(ExtendedDataOutputStream out) throws IOException
+ protected void requesting(ExtendedDataOutputStream out) throws Exception
{
out.writeInt(sessionID);
}
@Override
- protected Object confirming(ExtendedDataInputStream in) throws IOException
+ protected Object confirming(ExtendedDataInputStream in) throws Exception
{
return null;
}
diff --git a/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSRegisterConsumerRequest.java b/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSRegisterConsumerRequest.java
index 7e37a6a58e..29a614bc0f 100644
--- a/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSRegisterConsumerRequest.java
+++ b/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSRegisterConsumerRequest.java
@@ -17,7 +17,6 @@ import org.eclipse.net4j.signal.RequestWithConfirmation;
import org.eclipse.net4j.util.io.ExtendedDataInputStream;
import org.eclipse.net4j.util.io.ExtendedDataOutputStream;
-import java.io.IOException;
/**
* @author Eike Stepper
@@ -49,7 +48,7 @@ public class JMSRegisterConsumerRequest extends RequestWithConfirmation<Long>
}
@Override
- protected void requesting(ExtendedDataOutputStream out) throws IOException
+ protected void requesting(ExtendedDataOutputStream out) throws Exception
{
out.writeInt(sessionID);
DestinationUtil.write(out, destination);
@@ -59,7 +58,7 @@ public class JMSRegisterConsumerRequest extends RequestWithConfirmation<Long>
}
@Override
- protected Long confirming(ExtendedDataInputStream in) throws IOException
+ protected Long confirming(ExtendedDataInputStream in) throws Exception
{
return in.readLong();
}
diff --git a/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSRollbackRequest.java b/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSRollbackRequest.java
index a66cb66de8..e22fd63751 100644
--- a/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSRollbackRequest.java
+++ b/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSRollbackRequest.java
@@ -15,7 +15,6 @@ import org.eclipse.net4j.signal.RequestWithConfirmation;
import org.eclipse.net4j.util.io.ExtendedDataInputStream;
import org.eclipse.net4j.util.io.ExtendedDataOutputStream;
-import java.io.IOException;
/**
* @author Eike Stepper
@@ -34,13 +33,13 @@ public class JMSRollbackRequest extends RequestWithConfirmation<Boolean>
}
@Override
- protected void requesting(ExtendedDataOutputStream out) throws IOException
+ protected void requesting(ExtendedDataOutputStream out) throws Exception
{
out.writeInt(sessionID);
}
@Override
- protected Boolean confirming(ExtendedDataInputStream in) throws IOException
+ protected Boolean confirming(ExtendedDataInputStream in) throws Exception
{
return in.readBoolean();
}
diff --git a/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSServerMessageIndication.java b/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSServerMessageIndication.java
index a7120cd938..9f6d2f83e5 100644
--- a/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSServerMessageIndication.java
+++ b/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSServerMessageIndication.java
@@ -17,7 +17,6 @@ import org.eclipse.net4j.jms.JMSProtocolConstants;
import org.eclipse.net4j.signal.Indication;
import org.eclipse.net4j.util.io.ExtendedDataInputStream;
-import java.io.IOException;
/**
* @author Eike Stepper
@@ -33,7 +32,7 @@ public class JMSServerMessageIndication extends Indication
}
@Override
- protected void indicating(ExtendedDataInputStream in) throws IOException
+ protected void indicating(ExtendedDataInputStream in) throws Exception
{
int sessionID = in.readInt();
long consumerID = in.readLong();
diff --git a/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSSyncRequest.java b/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSSyncRequest.java
index b7abea36fe..fed2491c89 100644
--- a/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSSyncRequest.java
+++ b/plugins/org.eclipse.net4j.jms/src/org/eclipse/net4j/internal/jms/protocol/JMSSyncRequest.java
@@ -15,7 +15,6 @@ import org.eclipse.net4j.signal.RequestWithConfirmation;
import org.eclipse.net4j.util.io.ExtendedDataInputStream;
import org.eclipse.net4j.util.io.ExtendedDataOutputStream;
-import java.io.IOException;
/**
* @author Eike Stepper
@@ -33,13 +32,13 @@ public class JMSSyncRequest extends RequestWithConfirmation<Long>
}
@Override
- protected void requesting(ExtendedDataOutputStream out) throws IOException
+ protected void requesting(ExtendedDataOutputStream out) throws Exception
{
clientTime0 = System.currentTimeMillis();
}
@Override
- protected Long confirming(ExtendedDataInputStream in) throws IOException
+ protected Long confirming(ExtendedDataInputStream in) throws Exception
{
long serverTime = in.readLong();
long clientTime1 = System.currentTimeMillis();

Back to the top