public class ProxyConnector extends AbstractIoConnector
SocketConnector
to provide proxy
support, as suggested by MINA list discussions.
Operates by intercepting connect requests and replacing the endpoint address
with the proxy address, then adding a ProxyFilter
as the first
IoFilter
which performs any necessary handshaking with the proxy
before allowing data to flow normally. During the handshake, any outgoing
write requests are buffered.
AbstractIoService.ServiceOperationFuture
disposalLock, LOGGER, sessionConfig
Constructor and Description |
---|
ProxyConnector()
Creates a new proxy connector.
|
ProxyConnector(SocketConnector connector)
Creates a new proxy connector.
|
ProxyConnector(SocketConnector connector,
IoSessionConfig config,
Executor executor)
Creates a new proxy connector.
|
Modifier and Type | Method and Description |
---|---|
void |
cancelConnectFuture()
Cancels the real connection when reconnection is in use.
|
protected ConnectFuture |
connect0(SocketAddress remoteAddress,
SocketAddress localAddress,
IoSessionInitializer<? extends ConnectFuture> sessionInitializer)
Connects to the specified
address . |
protected void |
dispose0()
Implement this method to release any acquired resources.
|
protected ConnectFuture |
fireConnected(IoSession session)
Fires the connection event on the real future to notify the client.
|
SocketConnector |
getConnector() |
ProxyIoSession |
getProxyIoSession() |
IoSessionConfig |
getSessionConfig() |
TransportMetadata |
getTransportMetadata() |
void |
setProxyIoSession(ProxyIoSession proxyIoSession)
Sets the proxy session object of this connector.
|
connect, connect, connect, connect, connect, connect, finishSessionInitialization0, getConnectTimeout, getConnectTimeoutCheckInterval, getConnectTimeoutMillis, getDefaultLocalAddress, getDefaultRemoteAddress, setConnectTimeout, setConnectTimeoutCheckInterval, setConnectTimeoutMillis, setDefaultLocalAddress, setDefaultRemoteAddress, toString
addListener, broadcast, dispose, dispose, executeWorker, executeWorker, getActivationTime, getFilterChain, getFilterChainBuilder, getHandler, getListeners, getManagedSessionCount, getManagedSessions, getScheduledWriteBytes, getScheduledWriteMessages, getSessionDataStructureFactory, getStatistics, initSession, isActive, isDisposed, isDisposing, removeListener, setFilterChainBuilder, setHandler, setSessionDataStructureFactory
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
addListener, broadcast, dispose, dispose, getActivationTime, getFilterChain, getFilterChainBuilder, getHandler, getManagedSessionCount, getManagedSessions, getScheduledWriteBytes, getScheduledWriteMessages, getSessionDataStructureFactory, getStatistics, isActive, isDisposed, isDisposing, removeListener, setFilterChainBuilder, setHandler, setSessionDataStructureFactory
public ProxyConnector()
public ProxyConnector(SocketConnector connector)
connector
- Connector used to establish proxy connections.public ProxyConnector(SocketConnector connector, IoSessionConfig config, Executor executor)
connector
- The Connector used to establish proxy connections.config
- The session confiugarion to useexecutor
- The associated executorpublic IoSessionConfig getSessionConfig()
IoSession
s
created by this service.public ProxyIoSession getProxyIoSession()
ProxyIoSession
linked with this connector.public void setProxyIoSession(ProxyIoSession proxyIoSession)
proxyIoSession
- the configuration of this connector.protected ConnectFuture connect0(SocketAddress remoteAddress, SocketAddress localAddress, IoSessionInitializer<? extends ConnectFuture> sessionInitializer)
address
. If communication starts
successfully, events are fired to the connector's handler
.connect0
in class AbstractIoConnector
remoteAddress
- the remote address to connect tolocalAddress
- the local addresssessionInitializer
- the session initializerConnectFuture
that will tell the result of the connection attemptpublic void cancelConnectFuture()
protected ConnectFuture fireConnected(IoSession session)
session
- the current sessionpublic final SocketConnector getConnector()
SocketConnector
to be used for connections
to the proxy server.protected void dispose0() throws Exception
AbstractIoService.dispose()
.dispose0
in class AbstractIoService
Exception
- If the dispose failedpublic TransportMetadata getTransportMetadata()
TransportMetadata
that this service runs on.Copyright © 2004–2018 Apache MINA Project. All rights reserved.