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 to ESP data format, and publishes to ESP 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://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>