Examples of org.snmp4j.transport.DefaultTcpTransportMapping

org.snmp4j.transport.DefaultTcpTransportMapping
The DefaultTcpTransportMapping implements a TCP transport mapping with the Java 1.4 new IO API.
It uses a single thread for processing incoming and outgoing messages. The thread is started when the listen method is called, or when an outgoing request is sent using the sendMessage method. @author Frank Fock @version 1.11

          transportMappings[i] = new DefaultUdpTransportMapping(address);
        }
        else
        {
          TcpAddress address = new TcpAddress(_connectors[i].getInetAddress(), _connectors[i].getPort());
          transportMappings[i] = new DefaultTcpTransportMapping(address);
        }
      }
    }

View Full Code Here

    }


    private Snmp createSnmpSession() throws IOException {
        AbstractTransportMapping transport;
        if (address instanceof TcpAddress) {
            transport = new DefaultTcpTransportMapping();
        } else {
            transport = new DefaultUdpTransportMapping();
        }


        // Could save some CPU cycles:

View Full Code Here


        this.listenGenericAddress = GenericAddress.parse(this.endpoint.getAddress());


        // either tcp or udp
        if ("tcp".equals(endpoint.getProtocol())) {
            this.transport = new DefaultTcpTransportMapping((TcpAddress)this.listenGenericAddress);
        } else if ("udp".equals(endpoint.getProtocol())) {
            this.transport = new DefaultUdpTransportMapping((UdpAddress)this.listenGenericAddress);
        } else {
            throw new IllegalArgumentException("Unknown protocol: " + endpoint.getProtocol());
        }

View Full Code Here


        this.targetAddress = GenericAddress.parse(this.endpoint.getAddress());


        // either tcp or udp
        if ("tcp".equals(endpoint.getProtocol())) {
            this.transport = new DefaultTcpTransportMapping();
        } else if ("udp".equals(endpoint.getProtocol())) {
            this.transport = new DefaultUdpTransportMapping();
        } else {
            throw new IllegalArgumentException("Unknown protocol: " + endpoint.getProtocol());
        }

View Full Code Here

    TransportMapping transport;
    if (listenAddress instanceof UdpAddress) {
      transport = new DefaultUdpTransportMapping((UdpAddress)listenAddress);
    }
    else {
      transport = new DefaultTcpTransportMapping((TcpAddress)listenAddress);
    }
    snmp = new Snmp(dispatcher, transport);
    snmp.getMessageDispatcher().addMessageProcessingModel(new MPv1());
    snmp.getMessageDispatcher().addMessageProcessingModel(new MPv2c());
    snmp.getMessageDispatcher().addMessageProcessingModel(new MPv3());

View Full Code Here

      }
      TestMasterAgent sampleAgent = new TestMasterAgent(commandLineParameters);
      String agentXAddress =
          ((String)((List)commandLineParameters.get("X")).get(0)).substring(4);
      sampleAgent.agent.addAgentXTransportMapping(
          new DefaultTcpTransportMapping(new TcpAddress(agentXAddress)));
      sampleAgent.agent.run();
      sampleAgent.agent.getCommandProcessor().setAcceptNewContexts(true);
      while (true) {
        try {
          Thread.sleep(1000);

View Full Code Here


        this.listenGenericAddress = GenericAddress.parse(this.endpoint.getAddress());


        // either tcp or udp
        if ("tcp".equals(endpoint.getProtocol())) {
            this.transport = new DefaultTcpTransportMapping((TcpAddress)this.listenGenericAddress);
        } else if ("udp".equals(endpoint.getProtocol())) {
            this.transport = new DefaultUdpTransportMapping((UdpAddress)this.listenGenericAddress);
        } else {
            throw new IllegalArgumentException("Unknown protocol: " + endpoint.getProtocol());
        }

View Full Code Here


        this.targetAddress = GenericAddress.parse(this.endpoint.getAddress());


        // either tcp or udp
        if ("tcp".equals(endpoint.getProtocol())) {
            this.transport = new DefaultTcpTransportMapping();
        } else if ("udp".equals(endpoint.getProtocol())) {
            this.transport = new DefaultUdpTransportMapping();
        } else {
            throw new IllegalArgumentException("Unknown protocol: " + endpoint.getProtocol());
        }

View Full Code Here


        this.listenGenericAddress = GenericAddress.parse(this.endpoint.getAddress());


        // either tcp or udp
        if ("tcp".equals(endpoint.getProtocol())) {
            this.transport = new DefaultTcpTransportMapping((TcpAddress)this.listenGenericAddress);
        } else if ("udp".equals(endpoint.getProtocol())) {
            this.transport = new DefaultUdpTransportMapping((UdpAddress)this.listenGenericAddress);
        } else {
            throw new IllegalArgumentException("Unknown protocol: " + endpoint.getProtocol());
        }

View Full Code Here


        this.targetAddress = GenericAddress.parse(this.endpoint.getAddress());


        // either tcp or udp
        if ("tcp".equals(endpoint.getProtocol())) {
            this.transport = new DefaultTcpTransportMapping();
        } else if ("udp".equals(endpoint.getProtocol())) {
            this.transport = new DefaultUdpTransportMapping();
        } else {
            throw new IllegalArgumentException("Unknown protocol: " + endpoint.getProtocol());
        }

View Full Code Here

0 1

TOP

Related Classes of org.snmp4j.transport.DefaultTcpTransportMapping

org.apache.camel.component.snmp.SnmpOIDPoller

org.apache.camel.component.snmp.SnmpTrapConsumer

org.cipango.snmp.SnmpAgent

org.rhq.enterprise.server.plugins.alertSnmp.SnmpTrapSender

org.snmp4j.agent.agentx.master.test.TestMasterAgent

org.snmp4j.test.MultiThreadedTrapReceiver

org.snmp4j.transport.DefaultTcpTransportMapping.SocketEntry

org.snmp4j.util.WorkerTask

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.