org.thales.punch.netty.impl

Class SnmpServerImpl

java.lang.Object

org.thales.punch.netty.impl.NettyAbstractEndpoint

org.thales.punch.netty.impl.NettyAbstractServer

org.thales.punch.netty.impl.SnmpServerImpl

All Implemented Interfaces:

Runnable, EventListener, org.snmp4j.CommandResponder, NettySocketServer<String>

public class SnmpServerImpl
extends NettyAbstractServer
implements NettySocketServer<String>, org.snmp4j.CommandResponder

SNMP endpoint. Instead of doing it on top of Netty we use the Snmp4j socket listener. It embeds all the security model of SNMP.

This has thus nothing to do with Netty.

Field Summary

Fields inherited from class org.thales.punch.netty.impl.NettyAbstractServer

bossGroup, sslCtx, sslSessionResumption, workerGroup

Fields inherited from class org.thales.punch.netty.impl.NettyAbstractEndpoint

bootstrap, host, maxPayloadLength, metricsContext, port, protocol, readSocketTimeoutAction, readSocketTimeoutMs, ssl, sslCiphers, sslProtocol, sslProvider, useNettyCompression

Constructor Summary

Constructors

Constructor and Description
SnmpServerImpl(org.thales.punch.settings.api.ISettingsMap settings, org.thales.punch.libraries.metrics.api.IMetricContext metricsContext) Create a new SNMP server.

Method Summary

Modifier and Type	Method and Description
void	addListeningAddress(org.thales.punch.settings.api.ISettingsMap address) Add a listening socket to this server thread.
boolean	isStopped()
static String	jsonFromPdu(org.snmp4j.PDU pdu, org.snmp4j.smi.Address sourceAddress, byte[] securityName)
void	processPdu(org.snmp4j.CommandResponderEvent event)
void	run() Our contract is to not return until we are stopped.
SnmpServerImpl	setCallback(INettyReaderCallback<String> handler) Set the user callback to send him Netty Tuple containing a Json representation of SNMP traps.
void	stop() Stop the server.
String	toString()

Methods inherited from class org.thales.punch.netty.impl.NettyAbstractServer

start

Methods inherited from class org.thales.punch.netty.impl.NettyAbstractEndpoint

getFileFromString, getSslProvider

Methods inherited from class java.lang.Object

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

Constructor Detail

SnmpServerImpl

public SnmpServerImpl(org.thales.punch.settings.api.ISettingsMap settings,
                      org.thales.punch.libraries.metrics.api.IMetricContext metricsContext)

Create a new SNMP server.

Parameters:

settings -

metricsContext - the metric context

Method Detail

setCallback

public SnmpServerImpl setCallback(INettyReaderCallback<String> handler)

Set the user callback to send him Netty Tuple containing a Json representation of SNMP traps.

Specified by:

setCallback in interface NettySocketServer<String>

Parameters:

handler - your data callback

Returns:

this server

isStopped

public boolean isStopped()

Specified by:

isStopped in interface NettySocketServer<String>

Overrides:

isStopped in class NettyAbstractServer

Returns:

true is the server is stopped.

stop

public void stop()

Stop the server.

Specified by:

stop in interface NettySocketServer<String>

Overrides:

stop in class NettyAbstractServer

toString

public String toString()

Overrides:

toString in class Object

run

public void run()

Our contract is to not return until we are stopped.

Specified by:

run in interface Runnable

Specified by:

run in interface NettySocketServer<String>

jsonFromPdu

public static String jsonFromPdu(org.snmp4j.PDU pdu,
                                 org.snmp4j.smi.Address sourceAddress,
                                 byte[] securityName)

Parameters:

pdu -

sourceAddress -

securityName -

Returns:

a Json String representing the PDU content, inluding variables and values, originator network information, and SNMP-level metadata (community, version, pdu type)

processPdu

public void processPdu(org.snmp4j.CommandResponderEvent event)

Specified by:

processPdu in interface org.snmp4j.CommandResponder

addListeningAddress

public void addListeningAddress(org.thales.punch.settings.api.ISettingsMap address)

Description copied from interface: NettySocketServer

Add a listening socket to this server thread.

Specified by:

addListeningAddress in interface NettySocketServer<String>

Parameters:

address - the host port address.