Package org.apache.solr.util

Class SocketProxy

java.lang.Object
org.apache.solr.util.SocketProxy
public class SocketProxy extends Object
Kindly borrowed the idea and base implementation from the ActiveMQ project; useful for blocking traffic on a specified port.

  • Field Details

  • Constructor Details

  • Method Details

    • open

      public void open(URI uri) throws Exception
      Throws:
      Exception

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • setReceiveBufferSize

      public void setReceiveBufferSize(int receiveBufferSize)

    • setTarget

      public void setTarget(URI tcpBrokerUri)

    • getListenPort

      public int getListenPort()

    • getUrl

      public URI getUrl()

    • close

      public void close()

    • halfClose

      public void halfClose()

    • waitUntilClosed

      public boolean waitUntilClosed(long timeoutSeconds) throws InterruptedException
      Throws:
      InterruptedException

    • reopen

      public void reopen()

    • pause

      public void pause()

    • goOn

      public void goOn()

    • isPauseAtStart

      public boolean isPauseAtStart()

    • setPauseAtStart

      public void setPauseAtStart(boolean pauseAtStart)

    • getAcceptBacklog

      public int getAcceptBacklog()

    • setAcceptBacklog

      public void setAcceptBacklog(int acceptBacklog)