diff options
Diffstat (limited to 'plugins/org.eclipse.net4j')
3 files changed, 13 insertions, 2 deletions
diff --git a/plugins/org.eclipse.net4j/src/org/eclipse/net4j/signal/SignalActor.java b/plugins/org.eclipse.net4j/src/org/eclipse/net4j/signal/SignalActor.java index 951bff6200..10ee350ba7 100644 --- a/plugins/org.eclipse.net4j/src/org/eclipse/net4j/signal/SignalActor.java +++ b/plugins/org.eclipse.net4j/src/org/eclipse/net4j/signal/SignalActor.java @@ -13,6 +13,7 @@ package org.eclipse.net4j.signal; import org.eclipse.net4j.transport.BufferHandler; import org.eclipse.net4j.transport.Channel; import org.eclipse.net4j.transport.util.BufferInputStream; +import org.eclipse.net4j.util.ReflectUtil; /** * @author Eike Stepper @@ -52,7 +53,8 @@ public abstract class SignalActor<RESULT> extends Signal @Override public String toString() { - return "SignalActor[" + getSignalID() + ", " + getProtocol() + ", correlation=" //$NON-NLS-1$ //$NON-NLS-2$ //$NON-NLS-3$ + return ReflectUtil.getSimpleName(getClass()) + + "[" + getSignalID() + ", " + getProtocol() + ", correlation=" //$NON-NLS-1$ //$NON-NLS-2$ //$NON-NLS-3$ + getCorrelationID() + (terminated ? ", SENT" : "") + "]"; //$NON-NLS-1$ //$NON-NLS-2$ //$NON-NLS-3$ } diff --git a/plugins/org.eclipse.net4j/src/org/eclipse/net4j/signal/SignalReactor.java b/plugins/org.eclipse.net4j/src/org/eclipse/net4j/signal/SignalReactor.java index 55d43b78a1..ee2b28e89f 100644 --- a/plugins/org.eclipse.net4j/src/org/eclipse/net4j/signal/SignalReactor.java +++ b/plugins/org.eclipse.net4j/src/org/eclipse/net4j/signal/SignalReactor.java @@ -10,6 +10,8 @@ **************************************************************************/ package org.eclipse.net4j.signal; +import org.eclipse.net4j.util.ReflectUtil; + /** * @author Eike Stepper */ @@ -22,7 +24,8 @@ public abstract class SignalReactor extends Signal @Override public String toString() { - return "SignalReactor[" + getSignalID() + ", " + getProtocol() + ", correlation=" //$NON-NLS-1$ //$NON-NLS-2$ //$NON-NLS-3$ + return ReflectUtil.getSimpleName(getClass()) + + "[" + getSignalID() + ", " + getProtocol() + ", correlation=" //$NON-NLS-1$ //$NON-NLS-2$ //$NON-NLS-3$ + getCorrelationID() + "]"; //$NON-NLS-1$ } } diff --git a/plugins/org.eclipse.net4j/src/org/eclipse/net4j/transport/Connector.java b/plugins/org.eclipse.net4j/src/org/eclipse/net4j/transport/Connector.java index aa3e7ee002..c603b4f962 100644 --- a/plugins/org.eclipse.net4j/src/org/eclipse/net4j/transport/Connector.java +++ b/plugins/org.eclipse.net4j/src/org/eclipse/net4j/transport/Connector.java @@ -14,6 +14,8 @@ import org.eclipse.net4j.util.registry.HashMapRegistry; import org.eclipse.net4j.util.registry.IRegistry; import org.eclipse.net4j.util.registry.IRegistryElement; +import java.util.concurrent.ExecutorService; + /** * One endpoint of a physical connection of arbitrary nature between two * communicating parties. A {@link Connector} encapsulates the process of @@ -117,6 +119,10 @@ public interface Connector extends IRegistryElement<Integer> */ public void setProtocolFactoryRegistry(IRegistry<String, ProtocolFactory> protocolFactoryRegistry); + public ExecutorService getReceiveExecutor(); + + public void setReceiveExecutor(ExecutorService receiveExecutor); + public void addStateListener(StateListener listener); public void removeStateListener(StateListener listener); |