Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- <channel version="3.5.0">
- <id>8d978514-ddfc-4032-b3d5-c31eee880add</id>
- <nextMetaDataId>3</nextMetaDataId>
- <name>Example - Consolidate CSV</name>
- <description></description>
- <revision>1</revision>
- <sourceConnector version="3.5.0">
- <metaDataId>0</metaDataId>
- <name>sourceConnector</name>
- <properties class="com.mirth.connect.connectors.vm.VmReceiverProperties" version="3.5.0">
- <pluginProperties/>
- <sourceConnectorProperties version="3.5.0">
- <responseVariable>None</responseVariable>
- <respondAfterProcessing>true</respondAfterProcessing>
- <processBatch>true</processBatch>
- <firstResponse>false</firstResponse>
- <processingThreads>1</processingThreads>
- <resourceIds class="linked-hash-map">
- <entry>
- <string>Default Resource</string>
- <string>[Default Resource]</string>
- </entry>
- </resourceIds>
- <queueBufferSize>1000</queueBufferSize>
- </sourceConnectorProperties>
- </properties>
- <transformer version="3.5.0">
- <elements/>
- <inboundDataType>DELIMITED</inboundDataType>
- <outboundDataType>DELIMITED</outboundDataType>
- <inboundProperties class="com.mirth.connect.plugins.datatypes.delimited.DelimitedDataTypeProperties" version="3.5.0">
- <serializationProperties class="com.mirth.connect.plugins.datatypes.delimited.DelimitedSerializationProperties" version="3.5.0">
- <columnDelimiter>,</columnDelimiter>
- <recordDelimiter>\n</recordDelimiter>
- <quoteToken>"</quoteToken>
- <escapeWithDoubleQuote>true</escapeWithDoubleQuote>
- <quoteEscapeToken>\</quoteEscapeToken>
- <numberedRows>false</numberedRows>
- <ignoreCR>true</ignoreCR>
- </serializationProperties>
- <deserializationProperties class="com.mirth.connect.plugins.datatypes.delimited.DelimitedDeserializationProperties" version="3.5.0">
- <columnDelimiter>,</columnDelimiter>
- <recordDelimiter>\n</recordDelimiter>
- <quoteToken>"</quoteToken>
- <escapeWithDoubleQuote>true</escapeWithDoubleQuote>
- <quoteEscapeToken>\</quoteEscapeToken>
- </deserializationProperties>
- <batchProperties class="com.mirth.connect.plugins.datatypes.delimited.DelimitedBatchProperties" version="3.5.0">
- <splitType>Record</splitType>
- <batchSkipRecords>0</batchSkipRecords>
- <batchMessageDelimiter></batchMessageDelimiter>
- <batchMessageDelimiterIncluded>false</batchMessageDelimiterIncluded>
- <batchGroupingColumn></batchGroupingColumn>
- <batchScript></batchScript>
- </batchProperties>
- </inboundProperties>
- <outboundProperties class="com.mirth.connect.plugins.datatypes.delimited.DelimitedDataTypeProperties" version="3.5.0">
- <serializationProperties class="com.mirth.connect.plugins.datatypes.delimited.DelimitedSerializationProperties" version="3.5.0">
- <columnDelimiter>,</columnDelimiter>
- <recordDelimiter>\n</recordDelimiter>
- <quoteToken>"</quoteToken>
- <escapeWithDoubleQuote>true</escapeWithDoubleQuote>
- <quoteEscapeToken>\</quoteEscapeToken>
- <numberedRows>false</numberedRows>
- <ignoreCR>true</ignoreCR>
- </serializationProperties>
- <deserializationProperties class="com.mirth.connect.plugins.datatypes.delimited.DelimitedDeserializationProperties" version="3.5.0">
- <columnDelimiter>,</columnDelimiter>
- <recordDelimiter>\n</recordDelimiter>
- <quoteToken>"</quoteToken>
- <escapeWithDoubleQuote>true</escapeWithDoubleQuote>
- <quoteEscapeToken>\</quoteEscapeToken>
- </deserializationProperties>
- <batchProperties class="com.mirth.connect.plugins.datatypes.delimited.DelimitedBatchProperties" version="3.5.0">
- <splitType>Record</splitType>
- <batchSkipRecords>0</batchSkipRecords>
- <batchMessageDelimiter></batchMessageDelimiter>
- <batchMessageDelimiterIncluded>false</batchMessageDelimiterIncluded>
- <batchGroupingColumn></batchGroupingColumn>
- <batchScript></batchScript>
- </batchProperties>
- </outboundProperties>
- </transformer>
- <filter version="3.5.0">
- <elements/>
- </filter>
- <transportName>Channel Reader</transportName>
- <mode>SOURCE</mode>
- <enabled>true</enabled>
- <waitForPrevious>true</waitForPrevious>
- </sourceConnector>
- <destinationConnectors>
- <connector version="3.5.0">
- <metaDataId>1</metaDataId>
- <name>SOAP Endpoint</name>
- <properties class="com.mirth.connect.connectors.vm.VmDispatcherProperties" version="3.5.0">
- <pluginProperties/>
- <destinationConnectorProperties version="3.5.0">
- <queueEnabled>false</queueEnabled>
- <sendFirst>false</sendFirst>
- <retryIntervalMillis>10000</retryIntervalMillis>
- <regenerateTemplate>false</regenerateTemplate>
- <retryCount>0</retryCount>
- <rotate>false</rotate>
- <includeFilterTransformer>false</includeFilterTransformer>
- <threadCount>1</threadCount>
- <threadAssignmentVariable></threadAssignmentVariable>
- <validateResponse>false</validateResponse>
- <resourceIds class="linked-hash-map">
- <entry>
- <string>Default Resource</string>
- <string>[Default Resource]</string>
- </entry>
- </resourceIds>
- <queueBufferSize>1000</queueBufferSize>
- <reattachAttachments>true</reattachAttachments>
- </destinationConnectorProperties>
- <channelId>none</channelId>
- <channelTemplate>${message.encodedData}</channelTemplate>
- <mapVariables/>
- </properties>
- <transformer version="3.5.0">
- <elements/>
- <inboundDataType>DELIMITED</inboundDataType>
- <outboundDataType>DELIMITED</outboundDataType>
- <inboundProperties class="com.mirth.connect.plugins.datatypes.delimited.DelimitedDataTypeProperties" version="3.5.0">
- <serializationProperties class="com.mirth.connect.plugins.datatypes.delimited.DelimitedSerializationProperties" version="3.5.0">
- <columnDelimiter>,</columnDelimiter>
- <recordDelimiter>\n</recordDelimiter>
- <quoteToken>"</quoteToken>
- <escapeWithDoubleQuote>true</escapeWithDoubleQuote>
- <quoteEscapeToken>\</quoteEscapeToken>
- <numberedRows>false</numberedRows>
- <ignoreCR>true</ignoreCR>
- </serializationProperties>
- <deserializationProperties class="com.mirth.connect.plugins.datatypes.delimited.DelimitedDeserializationProperties" version="3.5.0">
- <columnDelimiter>,</columnDelimiter>
- <recordDelimiter>\n</recordDelimiter>
- <quoteToken>"</quoteToken>
- <escapeWithDoubleQuote>true</escapeWithDoubleQuote>
- <quoteEscapeToken>\</quoteEscapeToken>
- </deserializationProperties>
- <batchProperties class="com.mirth.connect.plugins.datatypes.delimited.DelimitedBatchProperties" version="3.5.0">
- <splitType>Record</splitType>
- <batchSkipRecords>0</batchSkipRecords>
- <batchMessageDelimiter></batchMessageDelimiter>
- <batchMessageDelimiterIncluded>false</batchMessageDelimiterIncluded>
- <batchGroupingColumn></batchGroupingColumn>
- <batchScript></batchScript>
- </batchProperties>
- </inboundProperties>
- <outboundProperties class="com.mirth.connect.plugins.datatypes.delimited.DelimitedDataTypeProperties" version="3.5.0">
- <serializationProperties class="com.mirth.connect.plugins.datatypes.delimited.DelimitedSerializationProperties" version="3.5.0">
- <columnDelimiter>,</columnDelimiter>
- <recordDelimiter>\n</recordDelimiter>
- <quoteToken>"</quoteToken>
- <escapeWithDoubleQuote>true</escapeWithDoubleQuote>
- <quoteEscapeToken>\</quoteEscapeToken>
- <numberedRows>false</numberedRows>
- <ignoreCR>true</ignoreCR>
- </serializationProperties>
- <deserializationProperties class="com.mirth.connect.plugins.datatypes.delimited.DelimitedDeserializationProperties" version="3.5.0">
- <columnDelimiter>,</columnDelimiter>
- <recordDelimiter>\n</recordDelimiter>
- <quoteToken>"</quoteToken>
- <escapeWithDoubleQuote>true</escapeWithDoubleQuote>
- <quoteEscapeToken>\</quoteEscapeToken>
- </deserializationProperties>
- <batchProperties class="com.mirth.connect.plugins.datatypes.delimited.DelimitedBatchProperties" version="3.5.0">
- <splitType>Record</splitType>
- <batchSkipRecords>0</batchSkipRecords>
- <batchMessageDelimiter></batchMessageDelimiter>
- <batchMessageDelimiterIncluded>false</batchMessageDelimiterIncluded>
- <batchGroupingColumn></batchGroupingColumn>
- <batchScript></batchScript>
- </batchProperties>
- </outboundProperties>
- </transformer>
- <responseTransformer version="3.5.0">
- <elements/>
- <inboundDataType>DELIMITED</inboundDataType>
- <outboundDataType>DELIMITED</outboundDataType>
- <inboundProperties class="com.mirth.connect.plugins.datatypes.delimited.DelimitedDataTypeProperties" version="3.5.0">
- <serializationProperties class="com.mirth.connect.plugins.datatypes.delimited.DelimitedSerializationProperties" version="3.5.0">
- <columnDelimiter>,</columnDelimiter>
- <recordDelimiter>\n</recordDelimiter>
- <quoteToken>"</quoteToken>
- <escapeWithDoubleQuote>true</escapeWithDoubleQuote>
- <quoteEscapeToken>\</quoteEscapeToken>
- <numberedRows>false</numberedRows>
- <ignoreCR>true</ignoreCR>
- </serializationProperties>
- <deserializationProperties class="com.mirth.connect.plugins.datatypes.delimited.DelimitedDeserializationProperties" version="3.5.0">
- <columnDelimiter>,</columnDelimiter>
- <recordDelimiter>\n</recordDelimiter>
- <quoteToken>"</quoteToken>
- <escapeWithDoubleQuote>true</escapeWithDoubleQuote>
- <quoteEscapeToken>\</quoteEscapeToken>
- </deserializationProperties>
- <batchProperties class="com.mirth.connect.plugins.datatypes.delimited.DelimitedBatchProperties" version="3.5.0">
- <splitType>Record</splitType>
- <batchSkipRecords>0</batchSkipRecords>
- <batchMessageDelimiter></batchMessageDelimiter>
- <batchMessageDelimiterIncluded>false</batchMessageDelimiterIncluded>
- <batchGroupingColumn></batchGroupingColumn>
- <batchScript></batchScript>
- </batchProperties>
- </inboundProperties>
- <outboundProperties class="com.mirth.connect.plugins.datatypes.delimited.DelimitedDataTypeProperties" version="3.5.0">
- <serializationProperties class="com.mirth.connect.plugins.datatypes.delimited.DelimitedSerializationProperties" version="3.5.0">
- <columnDelimiter>,</columnDelimiter>
- <recordDelimiter>\n</recordDelimiter>
- <quoteToken>"</quoteToken>
- <escapeWithDoubleQuote>true</escapeWithDoubleQuote>
- <quoteEscapeToken>\</quoteEscapeToken>
- <numberedRows>false</numberedRows>
- <ignoreCR>true</ignoreCR>
- </serializationProperties>
- <deserializationProperties class="com.mirth.connect.plugins.datatypes.delimited.DelimitedDeserializationProperties" version="3.5.0">
- <columnDelimiter>,</columnDelimiter>
- <recordDelimiter>\n</recordDelimiter>
- <quoteToken>"</quoteToken>
- <escapeWithDoubleQuote>true</escapeWithDoubleQuote>
- <quoteEscapeToken>\</quoteEscapeToken>
- </deserializationProperties>
- <batchProperties class="com.mirth.connect.plugins.datatypes.delimited.DelimitedBatchProperties" version="3.5.0">
- <splitType>Record</splitType>
- <batchSkipRecords>0</batchSkipRecords>
- <batchMessageDelimiter></batchMessageDelimiter>
- <batchMessageDelimiterIncluded>false</batchMessageDelimiterIncluded>
- <batchGroupingColumn></batchGroupingColumn>
- <batchScript></batchScript>
- </batchProperties>
- </outboundProperties>
- </responseTransformer>
- <filter version="3.5.0">
- <elements/>
- </filter>
- <transportName>Channel Writer</transportName>
- <mode>DESTINATION</mode>
- <enabled>true</enabled>
- <waitForPrevious>true</waitForPrevious>
- </connector>
- <connector version="3.5.0">
- <metaDataId>2</metaDataId>
- <name>Send Consolidated CSV</name>
- <properties class="com.mirth.connect.connectors.vm.VmDispatcherProperties" version="3.5.0">
- <pluginProperties/>
- <destinationConnectorProperties version="3.5.0">
- <queueEnabled>false</queueEnabled>
- <sendFirst>false</sendFirst>
- <retryIntervalMillis>10000</retryIntervalMillis>
- <regenerateTemplate>false</regenerateTemplate>
- <retryCount>0</retryCount>
- <rotate>false</rotate>
- <includeFilterTransformer>false</includeFilterTransformer>
- <threadCount>1</threadCount>
- <threadAssignmentVariable></threadAssignmentVariable>
- <validateResponse>false</validateResponse>
- <resourceIds class="linked-hash-map">
- <entry>
- <string>Default Resource</string>
- <string>[Default Resource]</string>
- </entry>
- </resourceIds>
- <queueBufferSize>1000</queueBufferSize>
- <reattachAttachments>true</reattachAttachments>
- </destinationConnectorProperties>
- <channelId>none</channelId>
- <channelTemplate>${message.encodedData}</channelTemplate>
- <mapVariables/>
- </properties>
- <transformer version="3.5.0">
- <elements>
- <com.mirth.connect.plugins.javascriptstep.JavaScriptStep>
- <name>Extract consolidated CSV</name>
- <sequenceNumber>0</sequenceNumber>
- <script>msg = SerializerFactory.getSerializer('DELIMITED').toXML($('csvMap').remove($('batchId')));</script>
- </com.mirth.connect.plugins.javascriptstep.JavaScriptStep>
- </elements>
- <inboundTemplate encoding="base64"></inboundTemplate>
- <outboundTemplate encoding="base64"></outboundTemplate>
- <inboundDataType>DELIMITED</inboundDataType>
- <outboundDataType>DELIMITED</outboundDataType>
- <inboundProperties class="com.mirth.connect.plugins.datatypes.delimited.DelimitedDataTypeProperties" version="3.5.0">
- <serializationProperties class="com.mirth.connect.plugins.datatypes.delimited.DelimitedSerializationProperties" version="3.5.0">
- <columnDelimiter>,</columnDelimiter>
- <recordDelimiter>\n</recordDelimiter>
- <quoteToken>"</quoteToken>
- <escapeWithDoubleQuote>true</escapeWithDoubleQuote>
- <quoteEscapeToken>\</quoteEscapeToken>
- <numberedRows>false</numberedRows>
- <ignoreCR>true</ignoreCR>
- </serializationProperties>
- <deserializationProperties class="com.mirth.connect.plugins.datatypes.delimited.DelimitedDeserializationProperties" version="3.5.0">
- <columnDelimiter>,</columnDelimiter>
- <recordDelimiter>\n</recordDelimiter>
- <quoteToken>"</quoteToken>
- <escapeWithDoubleQuote>true</escapeWithDoubleQuote>
- <quoteEscapeToken>\</quoteEscapeToken>
- </deserializationProperties>
- <batchProperties class="com.mirth.connect.plugins.datatypes.delimited.DelimitedBatchProperties" version="3.5.0">
- <splitType>Record</splitType>
- <batchSkipRecords>0</batchSkipRecords>
- <batchMessageDelimiter></batchMessageDelimiter>
- <batchMessageDelimiterIncluded>false</batchMessageDelimiterIncluded>
- <batchGroupingColumn></batchGroupingColumn>
- <batchScript></batchScript>
- </batchProperties>
- </inboundProperties>
- <outboundProperties class="com.mirth.connect.plugins.datatypes.delimited.DelimitedDataTypeProperties" version="3.5.0">
- <serializationProperties class="com.mirth.connect.plugins.datatypes.delimited.DelimitedSerializationProperties" version="3.5.0">
- <columnDelimiter>,</columnDelimiter>
- <recordDelimiter>\n</recordDelimiter>
- <quoteToken>"</quoteToken>
- <escapeWithDoubleQuote>true</escapeWithDoubleQuote>
- <quoteEscapeToken>\</quoteEscapeToken>
- <numberedRows>false</numberedRows>
- <ignoreCR>true</ignoreCR>
- </serializationProperties>
- <deserializationProperties class="com.mirth.connect.plugins.datatypes.delimited.DelimitedDeserializationProperties" version="3.5.0">
- <columnDelimiter>,</columnDelimiter>
- <recordDelimiter>\n</recordDelimiter>
- <quoteToken>"</quoteToken>
- <escapeWithDoubleQuote>true</escapeWithDoubleQuote>
- <quoteEscapeToken>\</quoteEscapeToken>
- </deserializationProperties>
- <batchProperties class="com.mirth.connect.plugins.datatypes.delimited.DelimitedBatchProperties" version="3.5.0">
- <splitType>Record</splitType>
- <batchSkipRecords>0</batchSkipRecords>
- <batchMessageDelimiter></batchMessageDelimiter>
- <batchMessageDelimiterIncluded>false</batchMessageDelimiterIncluded>
- <batchGroupingColumn></batchGroupingColumn>
- <batchScript></batchScript>
- </batchProperties>
- </outboundProperties>
- </transformer>
- <responseTransformer version="3.5.0">
- <elements/>
- <inboundDataType>DELIMITED</inboundDataType>
- <outboundDataType>DELIMITED</outboundDataType>
- <inboundProperties class="com.mirth.connect.plugins.datatypes.delimited.DelimitedDataTypeProperties" version="3.5.0">
- <serializationProperties class="com.mirth.connect.plugins.datatypes.delimited.DelimitedSerializationProperties" version="3.5.0">
- <columnDelimiter>,</columnDelimiter>
- <recordDelimiter>\n</recordDelimiter>
- <quoteToken>"</quoteToken>
- <escapeWithDoubleQuote>true</escapeWithDoubleQuote>
- <quoteEscapeToken>\</quoteEscapeToken>
- <numberedRows>false</numberedRows>
- <ignoreCR>true</ignoreCR>
- </serializationProperties>
- <deserializationProperties class="com.mirth.connect.plugins.datatypes.delimited.DelimitedDeserializationProperties" version="3.5.0">
- <columnDelimiter>,</columnDelimiter>
- <recordDelimiter>\n</recordDelimiter>
- <quoteToken>"</quoteToken>
- <escapeWithDoubleQuote>true</escapeWithDoubleQuote>
- <quoteEscapeToken>\</quoteEscapeToken>
- </deserializationProperties>
- <batchProperties class="com.mirth.connect.plugins.datatypes.delimited.DelimitedBatchProperties" version="3.5.0">
- <splitType>Record</splitType>
- <batchSkipRecords>0</batchSkipRecords>
- <batchMessageDelimiter></batchMessageDelimiter>
- <batchMessageDelimiterIncluded>false</batchMessageDelimiterIncluded>
- <batchGroupingColumn></batchGroupingColumn>
- <batchScript></batchScript>
- </batchProperties>
- </inboundProperties>
- <outboundProperties class="com.mirth.connect.plugins.datatypes.delimited.DelimitedDataTypeProperties" version="3.5.0">
- <serializationProperties class="com.mirth.connect.plugins.datatypes.delimited.DelimitedSerializationProperties" version="3.5.0">
- <columnDelimiter>,</columnDelimiter>
- <recordDelimiter>\n</recordDelimiter>
- <quoteToken>"</quoteToken>
- <escapeWithDoubleQuote>true</escapeWithDoubleQuote>
- <quoteEscapeToken>\</quoteEscapeToken>
- <numberedRows>false</numberedRows>
- <ignoreCR>true</ignoreCR>
- </serializationProperties>
- <deserializationProperties class="com.mirth.connect.plugins.datatypes.delimited.DelimitedDeserializationProperties" version="3.5.0">
- <columnDelimiter>,</columnDelimiter>
- <recordDelimiter>\n</recordDelimiter>
- <quoteToken>"</quoteToken>
- <escapeWithDoubleQuote>true</escapeWithDoubleQuote>
- <quoteEscapeToken>\</quoteEscapeToken>
- </deserializationProperties>
- <batchProperties class="com.mirth.connect.plugins.datatypes.delimited.DelimitedBatchProperties" version="3.5.0">
- <splitType>Record</splitType>
- <batchSkipRecords>0</batchSkipRecords>
- <batchMessageDelimiter></batchMessageDelimiter>
- <batchMessageDelimiterIncluded>false</batchMessageDelimiterIncluded>
- <batchGroupingColumn></batchGroupingColumn>
- <batchScript></batchScript>
- </batchProperties>
- </outboundProperties>
- </responseTransformer>
- <filter version="3.5.0">
- <elements>
- <com.mirth.connect.plugins.rulebuilder.RuleBuilderRule>
- <name>Accept message if "$('batchComplete')" equals true</name>
- <sequenceNumber>0</sequenceNumber>
- <field>$('batchComplete')</field>
- <condition>EQUALS</condition>
- <values>
- <string>true</string>
- </values>
- </com.mirth.connect.plugins.rulebuilder.RuleBuilderRule>
- </elements>
- </filter>
- <transportName>Channel Writer</transportName>
- <mode>DESTINATION</mode>
- <enabled>true</enabled>
- <waitForPrevious>true</waitForPrevious>
- </connector>
- </destinationConnectors>
- <preprocessingScript>// Modify the message variable below to pre process data
- var csvMap = $('csvMap');
- var batchId = $('batchId');
- if ($('batchSequenceId') == 1) {
- csvMap.put(batchId, new java.lang.String(message));
- } else {
- csvMap.put(batchId, csvMap.get(batchId).concat(message));
- }
- return message;</preprocessingScript>
- <postprocessingScript>// This script executes once after a message has been processed
- // Responses returned from here will be stored as "Postprocessor" in the response map
- return;</postprocessingScript>
- <deployScript>// This script executes once when the channel is deployed
- // You only have access to the globalMap and globalChannelMap here to persist data
- if (!globalChannelMap.containsKey('csvMap')) {
- $gc('csvMap', Maps.map());
- }
- return;</deployScript>
- <undeployScript>// This script executes once when the channel is undeployed
- // You only have access to the globalMap and globalChannelMap here to persist data
- return;</undeployScript>
- <properties version="3.5.0">
- <clearGlobalChannelMap>false</clearGlobalChannelMap>
- <messageStorageMode>DEVELOPMENT</messageStorageMode>
- <encryptData>false</encryptData>
- <removeContentOnCompletion>false</removeContentOnCompletion>
- <removeOnlyFilteredOnCompletion>false</removeOnlyFilteredOnCompletion>
- <removeAttachmentsOnCompletion>false</removeAttachmentsOnCompletion>
- <initialState>STARTED</initialState>
- <storeAttachments>false</storeAttachments>
- <metaDataColumns>
- <metaDataColumn>
- <name>SOURCE</name>
- <type>STRING</type>
- <mappingName>mirth_source</mappingName>
- </metaDataColumn>
- <metaDataColumn>
- <name>TYPE</name>
- <type>STRING</type>
- <mappingName>mirth_type</mappingName>
- </metaDataColumn>
- </metaDataColumns>
- <attachmentProperties version="3.5.0">
- <type>None</type>
- <properties/>
- </attachmentProperties>
- <resourceIds class="linked-hash-map">
- <entry>
- <string>Default Resource</string>
- <string>[Default Resource]</string>
- </entry>
- </resourceIds>
- </properties>
- <exportData>
- <metadata>
- <enabled>true</enabled>
- <lastModified>
- <time>1493736975808</time>
- <timezone>America/Los_Angeles</timezone>
- </lastModified>
- <pruningSettings>
- <archiveEnabled>true</archiveEnabled>
- </pruningSettings>
- </metadata>
- <channelTags/>
- </exportData>
- </channel>
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement