org.opennms.netmgt.provision.support
Class AsyncBasicDetector<Request,Response>

java.lang.Object
  org.opennms.netmgt.provision.support.AsyncAbstractDetector
      org.opennms.netmgt.provision.support.AsyncBasicDetector<Request,Response>

All Implemented Interfaces:

AsyncServiceDetector, ServiceDetector

Direct Known Subclasses:

AsyncLineOrientedDetector, AsyncMultilineDetector, HttpDetector, MultilineHttpDetector

public abstract class AsyncBasicDetector<Request,Response>
extends AsyncAbstractDetector

Abstract AsyncBasicDetector class.

Version:

$Id: $

Author:

Donald Desloge

Field Summary

protected static Charset

CHARSET_UTF8

Constructor Summary

AsyncBasicDetector(String serviceName, int port)
Constructor for AsyncBasicDetector.

AsyncBasicDetector(String serviceName, int port, int timeout, int retries)
Constructor for AsyncBasicDetector.

Method Summary

protected org.apache.mina.core.service.IoHandler	createDetectorHandler(DetectFuture future) createDetectorHandler
void	dispose() dispose
protected void	expectBanner(AsyncClientConversation.ResponseValidator<Response> bannerValidator) expectBanner
AsyncClientConversation.ResponseValidator<Response>	find(String regex) find
protected AsyncClientConversation<Request,Response>	getConversation() getConversation
protected org.apache.mina.core.service.IoHandler	getDetectorHandler() getDetectorHandler
int	getIdleTime() getIdleTime
protected org.apache.mina.core.filterchain.IoFilterAdapter	getLoggingFilter() getLoggingFilter
protected org.apache.mina.filter.codec.ProtocolCodecFilter	getProtocolCodecFilter() getProtocolCodecFilter
DetectFuture	isServiceDetected(InetAddress address, DetectorMonitor monitor) isServiceDetected
boolean	isUseSSLFilter() isUseSSLFilter
protected abstract void	onInit() onInit
protected Request	request(Request request) request
protected void	send(Request request, AsyncClientConversation.ResponseValidator<Response> responseValidator) send
protected void	setConversation(AsyncClientConversation<Request,Response> conversation) setConversation
protected void	setDetectorHandler(BaseDetectorHandler<Request,Response> detectorHandler) setDetectorHandler
void	setIdleTime(int idleTime) setIdleTime
protected void	setLoggingFilter(org.apache.mina.core.filterchain.IoFilterAdapter filterLogging) setLoggingFilter
protected void	setProtocolCodecFilter(org.apache.mina.filter.codec.ProtocolCodecFilter protocolCodecFilter) setProtocolCodecFilter
void	setUseSSLFilter(boolean useSSLFilter) Setter for the field useSSLFilter.
protected AsyncClientConversation.ResponseValidator<Response>	startsWith(String prefix) startsWith

Methods inherited from class org.opennms.netmgt.provision.support.AsyncAbstractDetector

getPort, getRetries, getServiceName, getTimeout, init, setPort, setRetries, setServiceName, setTimeout

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

CHARSET_UTF8

protected static final Charset CHARSET_UTF8

Constructor Detail

AsyncBasicDetector

public AsyncBasicDetector(String serviceName,
                          int port)

Constructor for AsyncBasicDetector.

Type Parameters:

Request - a Request object.

Response - a Response object.

Parameters:

serviceName - a String object.

port - a int.

AsyncBasicDetector

public AsyncBasicDetector(String serviceName,
                          int port,
                          int timeout,
                          int retries)

Constructor for AsyncBasicDetector.

Parameters:

serviceName - a String object.

port - a int.

timeout - a int.

retries - a int.

Method Detail

onInit

protected abstract void onInit()

onInit

Specified by:

onInit in class AsyncAbstractDetector

isServiceDetected

public DetectFuture isServiceDetected(InetAddress address,
                                      DetectorMonitor monitor)
                               throws Exception

isServiceDetected

Specified by:

isServiceDetected in interface AsyncServiceDetector

Specified by:

isServiceDetected in class AsyncAbstractDetector

Parameters:

address - a InetAddress object.

monitor - a DetectorMonitor object.

Returns:

a DetectFuture object.

Throws:

Exception - if any.

dispose

public void dispose()

dispose

Specified by:

dispose in interface ServiceDetector

Specified by:

dispose in class AsyncAbstractDetector

expectBanner

protected void expectBanner(AsyncClientConversation.ResponseValidator<Response> bannerValidator)

expectBanner

Parameters:

bannerValidator - a AsyncClientConversation.ResponseValidator object.

send

protected void send(Request request,
                    AsyncClientConversation.ResponseValidator<Response> responseValidator)

send

Parameters:

request - a Request object.

responseValidator - a AsyncClientConversation.ResponseValidator object.

setDetectorHandler

protected void setDetectorHandler(BaseDetectorHandler<Request,Response> detectorHandler)

setDetectorHandler

Parameters:

detectorHandler - a BaseDetectorHandler object.

createDetectorHandler

protected org.apache.mina.core.service.IoHandler createDetectorHandler(DetectFuture future)

createDetectorHandler

Parameters:

future - a DetectFuture object.

Returns:

a IoHandler object.

setLoggingFilter

protected void setLoggingFilter(org.apache.mina.core.filterchain.IoFilterAdapter filterLogging)

setLoggingFilter

Parameters:

filterLogging - a IoFilterAdapter object.

getLoggingFilter

protected org.apache.mina.core.filterchain.IoFilterAdapter getLoggingFilter()

getLoggingFilter

Returns:

a IoFilterAdapter object.

setProtocolCodecFilter

protected void setProtocolCodecFilter(org.apache.mina.filter.codec.ProtocolCodecFilter protocolCodecFilter)

setProtocolCodecFilter

Parameters:

protocolCodecFilter - a ProtocolCodecFilter object.

getProtocolCodecFilter

protected org.apache.mina.filter.codec.ProtocolCodecFilter getProtocolCodecFilter()

getProtocolCodecFilter

Returns:

a ProtocolCodecFilter object.

setIdleTime

public void setIdleTime(int idleTime)

setIdleTime

Parameters:

idleTime - a int.

getIdleTime

public int getIdleTime()

getIdleTime

Returns:

a int.

getDetectorHandler

protected org.apache.mina.core.service.IoHandler getDetectorHandler()

getDetectorHandler

Returns:

a IoHandler object.

setConversation

protected void setConversation(AsyncClientConversation<Request,Response> conversation)

setConversation

Parameters:

conversation - a AsyncClientConversation object.

getConversation

protected AsyncClientConversation<Request,Response> getConversation()

getConversation

Returns:

a AsyncClientConversation object.

request

protected Request request(Request request)

request

Parameters:

request - a Request object.

Returns:

a Request object.

startsWith

protected AsyncClientConversation.ResponseValidator<Response> startsWith(String prefix)

startsWith

Parameters:

prefix - a String object.

Returns:

a AsyncClientConversation.ResponseValidator object.

find

public AsyncClientConversation.ResponseValidator<Response> find(String regex)

find

Parameters:

regex - a String object.

Returns:

a AsyncClientConversation.ResponseValidator object.

setUseSSLFilter

public void setUseSSLFilter(boolean useSSLFilter)

Setter for the field useSSLFilter.

Parameters:

useSSLFilter - a boolean.

isUseSSLFilter

public boolean isUseSSLFilter()

isUseSSLFilter

Returns:

a boolean.