[jboss-cvs] JBossAS SVN: r110475 - branches/snmp4j-int/varia/src/main/java/org/jboss/jmx/adaptor/snmp/test.
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Thu Jan 27 16:45:11 EST 2011
Author: thauser at redhat.com
Date: 2011-01-27 16:45:11 -0500 (Thu, 27 Jan 2011)
New Revision: 110475
Modified:
branches/snmp4j-int/varia/src/main/java/org/jboss/jmx/adaptor/snmp/test/NotificationProducerService.java
Log:
added getNext, getBulk test functions.
Modified: branches/snmp4j-int/varia/src/main/java/org/jboss/jmx/adaptor/snmp/test/NotificationProducerService.java
===================================================================
--- branches/snmp4j-int/varia/src/main/java/org/jboss/jmx/adaptor/snmp/test/NotificationProducerService.java 2011-01-27 21:37:27 UTC (rev 110474)
+++ branches/snmp4j-int/varia/src/main/java/org/jboss/jmx/adaptor/snmp/test/NotificationProducerService.java 2011-01-27 21:45:11 UTC (rev 110475)
@@ -22,6 +22,7 @@
import java.io.IOException;
import java.net.InetAddress;
import java.net.UnknownHostException;
+import java.util.Vector;
import javax.management.Notification;
import org.jboss.jmx.adaptor.snmp.agent.EventTypes;
@@ -103,10 +104,12 @@
}
public void getBulk(){
- PDU pdu = new PDU();
+ log.debug("Executing GETBULK...");
+ PDU pdu = new PDU();
pdu.setType(PDU.GETBULK);
pdu.add(new VariableBinding(new OID("1.2.3.4.1.1")));
pdu.add(new VariableBinding(new OID("1.3.6.1.2.1.1.0")));
+ pdu.add(new VariableBinding(new OID("1.3.1.1")));
pdu.setMaxRepetitions(7);
pdu.setNonRepeaters(1);
CommunityTarget target = new CommunityTarget();
@@ -123,13 +126,7 @@
transport.listen();
System.out.println("READY: "+System.currentTimeMillis());
Snmp snmp = new Snmp(transport);
- long t1 = System.currentTimeMillis();
- System.out.println("SENDING: "+t1);
- System.out.println("PDU: "+pdu);
ResponseEvent responseEvent = snmp.send(pdu, target);
- long t2=System.currentTimeMillis();
- System.out.println("SENT: "+t2);
- System.out.println("ELAPSED: "+(t2-t1));
System.out.println("response " + responseEvent.toString());
PDU responsePDU = responseEvent.getResponse();
@@ -149,10 +146,51 @@
} catch (Exception e) {
System.out.println("Some Other exception!!");
}
-
-
+
}
+ /**
+ * Sends a test GETNEXT request
+ */
+ public void getNext(){
+ PDU pdu = new PDU();
+ pdu.setType(PDU.GETNEXT);
+ pdu.add(new VariableBinding(new OID("1.3.6.1.2.1.1")));
+
+
+ CommunityTarget target = new CommunityTarget();
+ OctetString community = new OctetString("public");
+ target.setCommunity(community);
+ target.setVersion(SnmpConstants.version2c);
+ Address targetAddress = GenericAddress.parse("udp:127.0.0.1/1161");
+ target.setAddress(targetAddress);
+ target.setRetries(2);
+ target.setTimeout(2000);
+ try {
+ DefaultUdpTransportMapping transport = new DefaultUdpTransportMapping();
+ transport.listen();
+ System.out.println("READY: "+System.currentTimeMillis());
+ Snmp snmp = new Snmp(transport);
+ ResponseEvent responseEvent = snmp.send(pdu, target);
+ System.out.println("response " + responseEvent.toString());
+ PDU responsePDU = responseEvent.getResponse();
+ if (responsePDU == null){
+ System.out.println("Request timed out");
+ }
+ else{
+ System.out.println("Received response "+responsePDU);
+ }
+ System.out.println("Peer Address: "+responseEvent.getPeerAddress());
+ } catch (UnknownHostException e1) {
+ // TODO Auto-generated catch block
+ e1.printStackTrace();
+ } catch (IOException e1) {
+ // TODO Auto-generated catch block
+ e1.printStackTrace();
+ } catch (Exception e) {
+ System.out.println("Some Other exception!!");
+ }
+ }
/**
* Sends a test GET request
@@ -162,42 +200,42 @@
public void get(){
PDU pdu = new PDU();
pdu.setType(PDU.GET);
- pdu.add(new VariableBinding(new OID("1.2.3.4.1.3")));
-
+ pdu.add(new VariableBinding(new OID("1.3.6.1.2.1.1.4")));
+
CommunityTarget target = new CommunityTarget();
- OctetString community = new OctetString("public");
- target.setCommunity(community);
- Address targetAddress = GenericAddress.parse("udp:127.0.0.1/1161");
+ target.setCommunity(new OctetString("public"));
+ target.setVersion(SnmpConstants.version2c);
+ Address targetAddress = GenericAddress.parse("udp:127.0.0.1/1161");
target.setAddress(targetAddress);
- target.setRetries(2);
- target.setTimeout(2000);
-
+ target.setRetries(2);
+ target.setTimeout(2000);
+
try {
-
- DefaultUdpTransportMapping transport = new DefaultUdpTransportMapping();
- transport.listen();
- Snmp snmp = new Snmp(transport);
- ResponseEvent responseEvent = snmp.send(pdu, target);
- System.out.println("response " + responseEvent.toString());
- // extract the response PDU (could be null if timed out)
+ DefaultUdpTransportMapping transport = new DefaultUdpTransportMapping();
- PDU responsePDU = responseEvent.getResponse();
- if (responsePDU == null){
- System.out.println("Request Timed out ...");
- }
- else {
- System.out.println("RESPONSE RECEIVED!");
+ transport.listen();
+ System.out.println("READY: "+System.currentTimeMillis());
+ Snmp snmp = new Snmp(transport);
+ ResponseEvent responseEvent = snmp.send(pdu, target);
+ System.out.println("response " + responseEvent.toString());
+ PDU responsePDU = responseEvent.getResponse();
+ if (responsePDU == null) {
+ System.out.println("Request timed out");
+ }
+ else {
+ // System.out.println("Received response "+response);
+ }
+ System.out.println("Peer Address: "+responseEvent.getPeerAddress());
System.out.println("responsePdu = " + responsePDU);
-
- }
+
} catch (UnknownHostException e1) {
- // TODO Auto-generated catch block
e1.printStackTrace();
} catch (IOException e1) {
- // TODO Auto-generated catch block
e1.printStackTrace();
+ } catch (Exception e) {
+ System.out.println("Some Other exception!!" + e);
}
-
+
}
/**
@@ -206,11 +244,9 @@
* @jmx:managed-operation
*/
public void set(){
- PDU pdu = new PDU();
- OID oidn = new OID("1.3.6.1.2.1.1.1");
- Variable var = new OctetString("MBean Set Test");
- VariableBinding varBind = new VariableBinding(oidn, var);
- pdu.add(varBind);
+ PDU pdu = new PDU();
+ pdu.add(new VariableBinding(new OID("1.3.6.1.2.1.1.1"), new OctetString("MBean Set Test")));
+
pdu.setType(PDU.SET);
CommunityTarget target = new CommunityTarget();
@@ -220,32 +256,35 @@
target.setAddress(targetAddress);
target.setRetries(2);
target.setTimeout(1000);
-
- try
- {
- DefaultUdpTransportMapping transport = new DefaultUdpTransportMapping();
- transport.listen();
- Snmp snmp = new Snmp(transport);
+ try{
+ DefaultUdpTransportMapping transport = new DefaultUdpTransportMapping();
+ transport.listen();
+ System.out.println("READY: "+System.currentTimeMillis());
+ Snmp snmp = new Snmp(transport);
+ ResponseEvent responseEvent = snmp.set(pdu, target);
+ System.out.println("response " + responseEvent.toString());
+
+ PDU responsePDU = responseEvent.getResponse();
- ResponseEvent responseEvent = snmp.set(pdu, target);
+ if (responsePDU == null){
+ System.out.println("Request timed out.");
+ }
+ else {
+ System.out.println("Received response "+responsePDU);
+ }
+ System.out.println("Peer Address: "+responseEvent.getPeerAddress());
- PDU responsePDU = responseEvent.getResponse();
-
- if (responsePDU == null){
- System.out.println("Request timed out.");
- }
- else {
- System.out.println("Received response "+responsePDU);
- }
- System.out.println("Peer Address: "+responseEvent.getPeerAddress());
- } catch (UnknownHostException e1) {
- e1.printStackTrace();
- } catch (IOException e1) {
- e1.printStackTrace();
- } catch (Exception e) {
- System.out.println("Some Other exception!!");
- }
+ } catch (UnknownHostException e1) {
+ // TODO Auto-generated catch block
+ e1.printStackTrace();
+ } catch (IOException e1) {
+ // TODO Auto-generated catch block
+ e1.printStackTrace();
+ } catch (Exception e) {
+ System.out.println("Some Other exception!!");
+ }
+
}
More information about the jboss-cvs-commits
mailing list