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


构造方法摘要
DummyConnection()
           
 
方法摘要
 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.