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>60</Retryperiod> <Blocksize>512</Blocksize> <KeepAlive>true</KeepAlive> </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> <ProjectName>EspProject1</ProjectName> <StreamName>BaseInput</StreamName> <MaxPubPoolSize>1</MaxPubPoolSize> <UseTransactions>false</UseTransactions> <SafeOps>true</SafeOps> <SkipDels>true</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>Sybase123</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>