com.taobao.metamorphosis.gregor.slave
类 DummyConnection
java.lang.Object
com.taobao.metamorphosis.gregor.slave.DummyConnection
- 所有已实现的接口:
- com.taobao.gecko.service.Connection
public class DummyConnection
- extends Object
- implements com.taobao.gecko.service.Connection
方法摘要 |
Future<Boolean> |
asyncSend(com.taobao.gecko.core.command.RequestCommand requestCommand)
|
Set<String> |
attributeKeySet()
|
void |
clearAttributes()
|
void |
close(boolean allowReconnect)
|
Object |
getAttribute(String key)
|
Set<String> |
getGroupSet()
|
InetAddress |
getLocalAddress()
|
InetSocketAddress |
getRemoteSocketAddress()
|
com.taobao.gecko.service.RemotingContext |
getRemotingContext()
|
com.taobao.gecko.core.command.ResponseCommand |
invoke(com.taobao.gecko.core.command.RequestCommand request)
|
com.taobao.gecko.core.command.ResponseCommand |
invoke(com.taobao.gecko.core.command.RequestCommand requestCommand,
long time,
TimeUnit timeUnit)
|
boolean |
isConnected()
|
ByteOrder |
readBufferOrder()
|
void |
readBufferOrder(ByteOrder byteOrder)
|
void |
removeAttribute(String key)
|
void |
response(Object responseCommand)
|
void |
send(com.taobao.gecko.core.command.RequestCommand requestCommand)
|
void |
send(com.taobao.gecko.core.command.RequestCommand requestCommand,
com.taobao.gecko.service.SingleRequestCallBackListener listener)
|
void |
send(com.taobao.gecko.core.command.RequestCommand requestCommand,
com.taobao.gecko.service.SingleRequestCallBackListener listener,
long time,
TimeUnit timeUnit)
|
void |
setAttribute(String key,
Object value)
|
Object |
setAttributeIfAbsent(String key,
Object value)
|
void |
setWriteInterruptibly(boolean writeInterruptibly)
|
void |
transferFrom(com.taobao.gecko.core.buffer.IoBuffer head,
com.taobao.gecko.core.buffer.IoBuffer tail,
FileChannel channel,
long position,
long size)
|
void |
transferFrom(com.taobao.gecko.core.buffer.IoBuffer head,
com.taobao.gecko.core.buffer.IoBuffer tail,
FileChannel channel,
long position,
long size,
Integer opaque,
com.taobao.gecko.service.SingleRequestCallBackListener listener,
long time,
TimeUnit unit)
|
从类 java.lang.Object 继承的方法 |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
DummyConnection
public DummyConnection()
asyncSend
public Future<Boolean> asyncSend(com.taobao.gecko.core.command.RequestCommand requestCommand)
throws com.taobao.gecko.service.exception.NotifyRemotingException
- 指定者:
- 接口
com.taobao.gecko.service.Connection
中的 asyncSend
- 抛出:
com.taobao.gecko.service.exception.NotifyRemotingException
attributeKeySet
public Set<String> attributeKeySet()
- 指定者:
- 接口
com.taobao.gecko.service.Connection
中的 attributeKeySet
clearAttributes
public void clearAttributes()
- 指定者:
- 接口
com.taobao.gecko.service.Connection
中的 clearAttributes
close
public void close(boolean allowReconnect)
throws com.taobao.gecko.service.exception.NotifyRemotingException
- 指定者:
- 接口
com.taobao.gecko.service.Connection
中的 close
- 抛出:
com.taobao.gecko.service.exception.NotifyRemotingException
getAttribute
public Object getAttribute(String key)
- 指定者:
- 接口
com.taobao.gecko.service.Connection
中的 getAttribute
getGroupSet
public Set<String> getGroupSet()
- 指定者:
- 接口
com.taobao.gecko.service.Connection
中的 getGroupSet
getLocalAddress
public InetAddress getLocalAddress()
- 指定者:
- 接口
com.taobao.gecko.service.Connection
中的 getLocalAddress
getRemoteSocketAddress
public InetSocketAddress getRemoteSocketAddress()
- 指定者:
- 接口
com.taobao.gecko.service.Connection
中的 getRemoteSocketAddress
getRemotingContext
public com.taobao.gecko.service.RemotingContext getRemotingContext()
- 指定者:
- 接口
com.taobao.gecko.service.Connection
中的 getRemotingContext
invoke
public com.taobao.gecko.core.command.ResponseCommand invoke(com.taobao.gecko.core.command.RequestCommand requestCommand,
long time,
TimeUnit timeUnit)
throws InterruptedException,
TimeoutException,
com.taobao.gecko.service.exception.NotifyRemotingException
- 指定者:
- 接口
com.taobao.gecko.service.Connection
中的 invoke
- 抛出:
InterruptedException
TimeoutException
com.taobao.gecko.service.exception.NotifyRemotingException
invoke
public com.taobao.gecko.core.command.ResponseCommand invoke(com.taobao.gecko.core.command.RequestCommand request)
throws InterruptedException,
TimeoutException,
com.taobao.gecko.service.exception.NotifyRemotingException
- 指定者:
- 接口
com.taobao.gecko.service.Connection
中的 invoke
- 抛出:
InterruptedException
TimeoutException
com.taobao.gecko.service.exception.NotifyRemotingException
isConnected
public boolean isConnected()
- 指定者:
- 接口
com.taobao.gecko.service.Connection
中的 isConnected
readBufferOrder
public ByteOrder readBufferOrder()
- 指定者:
- 接口
com.taobao.gecko.service.Connection
中的 readBufferOrder
readBufferOrder
public void readBufferOrder(ByteOrder byteOrder)
- 指定者:
- 接口
com.taobao.gecko.service.Connection
中的 readBufferOrder
removeAttribute
public void removeAttribute(String key)
- 指定者:
- 接口
com.taobao.gecko.service.Connection
中的 removeAttribute
response
public void response(Object responseCommand)
throws com.taobao.gecko.service.exception.NotifyRemotingException
- 指定者:
- 接口
com.taobao.gecko.service.Connection
中的 response
- 抛出:
com.taobao.gecko.service.exception.NotifyRemotingException
send
public void send(com.taobao.gecko.core.command.RequestCommand requestCommand,
com.taobao.gecko.service.SingleRequestCallBackListener listener,
long time,
TimeUnit timeUnit)
throws com.taobao.gecko.service.exception.NotifyRemotingException
- 指定者:
- 接口
com.taobao.gecko.service.Connection
中的 send
- 抛出:
com.taobao.gecko.service.exception.NotifyRemotingException
send
public void send(com.taobao.gecko.core.command.RequestCommand requestCommand,
com.taobao.gecko.service.SingleRequestCallBackListener listener)
throws com.taobao.gecko.service.exception.NotifyRemotingException
- 指定者:
- 接口
com.taobao.gecko.service.Connection
中的 send
- 抛出:
com.taobao.gecko.service.exception.NotifyRemotingException
send
public void send(com.taobao.gecko.core.command.RequestCommand requestCommand)
throws com.taobao.gecko.service.exception.NotifyRemotingException
- 指定者:
- 接口
com.taobao.gecko.service.Connection
中的 send
- 抛出:
com.taobao.gecko.service.exception.NotifyRemotingException
setAttribute
public void setAttribute(String key,
Object value)
- 指定者:
- 接口
com.taobao.gecko.service.Connection
中的 setAttribute
setAttributeIfAbsent
public Object setAttributeIfAbsent(String key,
Object value)
- 指定者:
- 接口
com.taobao.gecko.service.Connection
中的 setAttributeIfAbsent
setWriteInterruptibly
public void setWriteInterruptibly(boolean writeInterruptibly)
- 指定者:
- 接口
com.taobao.gecko.service.Connection
中的 setWriteInterruptibly
transferFrom
public void transferFrom(com.taobao.gecko.core.buffer.IoBuffer head,
com.taobao.gecko.core.buffer.IoBuffer tail,
FileChannel channel,
long position,
long size)
- 指定者:
- 接口
com.taobao.gecko.service.Connection
中的 transferFrom
transferFrom
public void transferFrom(com.taobao.gecko.core.buffer.IoBuffer head,
com.taobao.gecko.core.buffer.IoBuffer tail,
FileChannel channel,
long position,
long size,
Integer opaque,
com.taobao.gecko.service.SingleRequestCallBackListener listener,
long time,
TimeUnit unit)
throws com.taobao.gecko.service.exception.NotifyRemotingException
- 指定者:
- 接口
com.taobao.gecko.service.Connection
中的 transferFrom
- 抛出:
com.taobao.gecko.service.exception.NotifyRemotingException
Copyright © 2010–2013. All rights reserved.