Show TOC

Sample Configuration File: Socket CSV Input AdapterLocate this document in the navigation structure

Sample adapter configuration file for the Socket CSV Input adapter.

<?xml version="1.0" encoding="utf-8"?>
<Adapter>
  <Name>socket_csv_input</Name>
  <Description>An adapter which gets csv string from socket server, transforms it to ESP data format, and publishes to a stream.</Description>
  <Log4jProperty>./log4j.properties</Log4jProperty>
  <Modules>
    <Module type="transporter">
      <InstanceName>MyExampleSocketInTransporter</InstanceName>
      <Name>SocketInputTransporter</Name>
      <Next>MyStreamingInputFormatter</Next>
      <Parameters>
        <SocketInputTransporterParameters>
          <Host>localhost</Host>
          <Port>9998</Port>
          <EpFile></EpFile>
          <RetryPeriod>1000</RetryPeriod>
          <InputBufferSize>512</InputBufferSize>
		  <KeepAlive>true</KeepAlive>
          <RetryNumber>30</RetryNumber>
        </SocketInputTransporterParameters>
      </Parameters>
    </Module>

     <Module type="formatter">	 
      <InstanceName>MyStreamingInputFormatter</InstanceName>
      <Name>StreamToStringFormatter</Name>
      <Next>MyCSVInputFormatter</Next>
      <Parameters>
        <StreamToStringFormatterParameters>
          <Delimiter>\n</Delimiter>
		  <IncludeDelimiter>false</IncludeDelimiter>
		  <AppendString></AppendString>
		  <AppendPosition>front</AppendPosition>
		  <IgnoreSpace>true</IgnoreSpace>		  
	   </StreamToStringFormatterParameters>
      </Parameters>
    </Module>
	
	<Module type="formatter">
		<InstanceName>MyCSVInputFormatter</InstanceName>
		<Name>CsvStringToEspFormatter</Name>
		<Next>MyInStream_Publisher</Next>
		<Parallel>true</Parallel>
		<Parameters>
		</Parameters>
	</Module>

    <Module type="espconnector">
      <InstanceName>MyInStream_Publisher</InstanceName>
      <Name>EspPublisher</Name>
      <Parameters>
        <EspPublisherParameters>
		  <!--Uncomment the following 2 elements when you use 'start_adapter[.bat|.sh]' -->
          <!--ProjectName>EspProject1</ProjectName-->
          <!--StreamName>BaseInput</StreamName-->
          <MaxPubPoolSize>1</MaxPubPoolSize>
          <UseTransactions>false</UseTransactions>
          <SafeOps>false</SafeOps>
          <SkipDels>false</SkipDels>		  
        </EspPublisherParameters>
      </Parameters>
      <BufferMaxSize>10240</BufferMaxSize>
    </Module>

 </Modules>
 
  <EspProjects>
    <EspProject>
      <Name>EspProject1</Name>
      <Uri>esp[s]://localhost:19011/sample_workspace/socket_csv_input</Uri>
      
      <Security>
        <User></User>
        <Password encrypted="false"></Password>
         <AuthType>user_password</AuthType>
        <!--	
    	  <RSAKeyStore>/keystore/keystore.jks</RSAKeyStore>
	      <RSAKeyStorePassword></RSAKeyStorePassword>
        -->
        <!--
	     <KerberosKDC>KDC</KerberosKDC>
	     <KerberosRealm>REALM</KerberosRealm>
 	     <KerberosService>service/instance</KerberosService>
	     <KerberosTicketCache>/tmp/krb5cc_user</KerberosTicketCache>
        -->
        <EncryptionAlgorithm>RSA</EncryptionAlgorithm>
      </Security>
    </EspProject>
  </EspProjects>
  <GlobalParameters></GlobalParameters>
</Adapter>