New SNMP Component

[Anonymous]

I've been trying to develop a new component for sending simple SNMP messages from Talend. Think of it as an alternative to a tWarn. However, my java skills are lacking, and I'm kind of stuck.
Basically, I keep getting a NullPointer exception and I'm not sure why. My component uses the SNMP4J library. This component isn't finished yet, but if someone could have a look and maybe point me in the right direction I would be most grateful.
Here are the files to create the component. You can find it under the "Internet" heading. It's called tSNMP.
tSNMP_main.javajet

<%@ jet 
	imports="
		org.talend.core.model.process.INode 
		org.talend.core.model.process.ElementParameterParser 
		org.talend.core.model.metadata.IMetadataTable 
		org.talend.core.model.metadata.IMetadataColumn 
		org.talend.core.model.process.IConnection
		org.talend.core.model.process.IConnectionCategory
		org.talend.designer.codegen.config.CodeGeneratorArgument
		org.talend.core.model.metadata.types.JavaTypesManager
		org.talend.core.model.metadata.types.JavaType
		java.util.List 
    	java.util.Map
    	java.util.StringTokenizer
    	java.net.InetAddress
    	
	" 
%>
<% 
    CodeGeneratorArgument codeGenArgument = (CodeGeneratorArgument) argument;
    INode node = (INode)codeGenArgument.getArgument();
    String cid = node.getUniqueName();
    
    
	//InetAddress snmp_server = InetAddress.getByName(ElementParameterParser.getValue(node, "__SNMP_SERVER__"));
	//InetAddress snmp_server = InetAddress.getByName("noc1-iis1.uscc.com");
	String snmp_server = ElementParameterParser.getValue(node, "__SNMP_SERVER__");
    int snmp_port = Integer.parseInt(ElementParameterParser.getValue(node, "__SNMP_SERVER_PORT__"));
    String snmp_oid = ElementParameterParser.getValue(node, "__OID__");
    String snmp_com = ElementParameterParser.getValue(node, "__COMMUNITY_STRING__");
    String snmp_msg = ElementParameterParser.getValue(node, "__SNMP_MSG__");
    
        
    
%>
   org.snmp4j.Snmp mSnmp = null;
   org.snmp4j.CommunityTarget mCommunityTarget = null;
   
   org.snmp4j.TransportMapping vTransport = new org.snmp4j.transport.DefaultUdpTransportMapping();
   mSnmp = new org.snmp4j.Snmp(vTransport);
   org.snmp4j.PDUv1 vTrapPdu = new org.snmp4j.PDUv1();
   vTransport.listen();
   
   //SETUP FROM USER
   mCommunityTarget.setCommunity(new org.snmp4j.smi.OctetString(<%=snmp_com %>));
   mCommunityTarget.setAddress(new org.snmp4j.smi.UdpAddress(java.net.InetAddress.getByName(<%=snmp_server %>),<%=snmp_port %>));   
   mCommunityTarget.setRetries(4);
   mCommunityTarget.setTimeout(4096);
   mCommunityTarget.setVersion(org.snmp4j.mp.SnmpConstants.version1);
   //vTrapPdu.setType(org.snmp4j.PDU.V1TRAP);
   vTrapPdu.setGenericTrap(6);
   vTrapPdu.setSpecificTrap(org.snmp4j.PDUv1.ENTERPRISE_SPECIFIC);
     
   vTrapPdu.setEnterprise(new org.snmp4j.smi.OID(<%=snmp_oid %>));
   vTrapPdu.setTimestamp((long)java.lang.System.currentTimeMillis()/10l);
   vTrapPdu.add(new org.snmp4j.smi.VariableBinding(new org.snmp4j.smi.OID(<%=snmp_oid %>), new org.snmp4j.smi.OctetString(<%=snmp_msg %>)));
   mSnmp.send(vTrapPdu, mCommunityTarget);

tSNMP_java.xml

<?xml version="1.0" encoding="UTF-8"?>
<COMPONENT> 
  <HEADER AUTHOR="Dustin W" COMPATIBILITY="ALL" DATA_AUTO_PROPAGATE="false" PLATEFORM="ALL" RELEASE_DATE="20080229A" SERIAL="" STARTABLE="true" STATUS="ALPHA" VERSION="0.1"> 
    <SIGNATURE/> 
  </HEADER>  
  <DOCUMENTATION> 
    <URL/> 
  </DOCUMENTATION>  
  <CONNECTORS>
    <CONNECTOR CTYPE="SUBJOB_OK" MAX_INPUT="1" />
    <CONNECTOR CTYPE="SUBJOB_ERROR" MAX_INPUT="1" />
    <CONNECTOR CTYPE="COMPONENT_OK"/>
    <CONNECTOR CTYPE="COMPONENT_ERROR"/>
    <CONNECTOR CTYPE="RUN_IF"/>	
</CONNECTORS>  
  <PARAMETERS> 
    <PARAMETER FIELD="TEXT" NAME="SNMP_SERVER" REQUIRED="true" NB_LINES="1" NUM_ROW="10"> <DEFAULT>"127.0.0.1"</DEFAULT> </PARAMETER> 
    <PARAMETER FIELD="TEXT" NAME="SNMP_SERVER_PORT" REQUIRED="true" NB_LINES="1" NUM_ROW="10"> <DEFAULT>162</DEFAULT> </PARAMETER> 
    <PARAMETER FIELD="TEXT" NAME="OID" NB_LINES="1" REQUIRED="true" NUM_ROW="30"> <DEFAULT>".1.3.6.1.4.1.99998"</DEFAULT> </PARAMETER> 
    <PARAMETER FIELD="TEXT" NAME="COMMUNITY_STRING" REQUIRED="true" NB_LINES="1" NUM_ROW="40"> <DEFAULT>"public"</DEFAULT> </PARAMETER>
    <PARAMETER FIELD="TEXT" NAME="SNMP_MSG" REQUIRED="true" NB_LINES="1" NUM_ROW="50"> <DEFAULT>"Your custom error message goes here"</DEFAULT> </PARAMETER>
    
  </PARAMETERS>  
  <CODEGENERATION> 
    <IMPORTS>
    <IMPORT NAME="SNMP4J" MODULE="SNMP4J.jar" REQUIRED="true"/>
    </IMPORTS>
  </CODEGENERATION>  
  <RETURNS></RETURNS> 
</COMPONENT>

tSNMP_messages.properties

#
#Tue Nov 25 18:13:37 CST 2008
PROPERTY.NAME=PROPERTY
OID.NAME=OID
NB_LINE.NAME=NB_LINE
FAMILY=Internet
HELP=org.talend.help.tSNMP
LONG_NAME=Send SNMP trap message
SNMP_SERVER.NAME=SNMP Server
COMMUNITY_STRING.NAME=Community String
SNMP_MSG.NAME=SNMP Message
NAME=tSNMP
SNMP_SERVER_PORT.NAME=SNMP Server Port

[Anonymous]

dweaver,
Thank you so much for creating this component!
It took me some time to figure out how it works ( as I didn't know anything about SNMP myself) and now that it's working it fits the needs.
So once again thanks for creating and sharing this component with the community!!
Regards,
Mario De Pauw