INTERLIS leicht gemacht #42 - INTERLIS over the wire

import stomp

# Create a connection to ActiveMQ
conn = stomp.Connection12([('localhost', 61613)], auto_content_length=False) #https://github.com/jasonrbriggs/stomp.py/issues/216
conn.connect(login='admin', passcode='admin', wait=True)

# Send a message to a specific destination (queue)
destination = 'ch/so/dsbjd/ebau'
message = '''<?xml version="1.0" encoding="UTF-8"?>
<ili:transfer xmlns:ili="http://www.interlis.ch/xtf/2.4/INTERLIS" xmlns:geom="http://www.interlis.ch/geometry/1.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:SO_ARP_Baugis_20190612="http://www.interlis.ch/xtf/2.4/SO_ARP_Baugis_20190612">
  <ili:headersection>
    <ili:models>
      <ili:model>SO_ARP_Baugis_20190612</ili:model>
    </ili:models>
    <ili:sender>ili2gpkg-5.1.0-58fc980cc6639b2c16a3cff8a0fa19ef1484b11c</ili:sender>
  </ili:headersection>
  <ili:datasection>
    <SO_ARP_Baugis_20190612:Baugis ili:bid="SO_ARP_Baugis_20190612.Baugis">
      <SO_ARP_Baugis_20190612:Geschaeft ili:tid="E888E057-B203-4488-866F-0EA1D365AFEF">
        <SO_ARP_Baugis_20190612:SobauID_sprechend>Neubau Zürihaus</SO_ARP_Baugis_20190612:SobauID_sprechend>
        <SO_ARP_Baugis_20190612:SobauID_system>08DE6290-A2EF-4044-9C49-3B9A1F280610</SO_ARP_Baugis_20190612:SobauID_system>
        <SO_ARP_Baugis_20190612:Art_Text>foo</SO_ARP_Baugis_20190612:Art_Text>
        <SO_ARP_Baugis_20190612:Art_Code>1</SO_ARP_Baugis_20190612:Art_Code>
        <SO_ARP_Baugis_20190612:Vorhaben>Gaga</SO_ARP_Baugis_20190612:Vorhaben>
        <SO_ARP_Baugis_20190612:Entscheid_Text>Ja</SO_ARP_Baugis_20190612:Entscheid_Text>
        <SO_ARP_Baugis_20190612:Entscheid_Code>1</SO_ARP_Baugis_20190612:Entscheid_Code>
        <SO_ARP_Baugis_20190612:Sistiert_Text>nein</SO_ARP_Baugis_20190612:Sistiert_Text>
        <SO_ARP_Baugis_20190612:Sistiert_Code>2</SO_ARP_Baugis_20190612:Sistiert_Code>
        <SO_ARP_Baugis_20190612:Sobau_Link>https://agi.so.ch</SO_ARP_Baugis_20190612:Sobau_Link>
        <SO_ARP_Baugis_20190612:Projektleiter_Name>Lisa Liegenschaft</SO_ARP_Baugis_20190612:Projektleiter_Name>
        <SO_ARP_Baugis_20190612:Geometrie>
          <geom:coord>
            <geom:c1>2607892.464</geom:c1>
            <geom:c2>1228257.773</geom:c2>
          </geom:coord>
        </SO_ARP_Baugis_20190612:Geometrie>
      </SO_ARP_Baugis_20190612:Geschaeft>
    </SO_ARP_Baugis_20190612:Baugis>
  </ili:datasection>
</ili:transfer>
'''

conn.send(body=message, destination=destination, headers={'persistent' :'true'})

# Disconnect from ActiveMQ
conn.disconnect()

//REPOS mavencentral,ehi=https://jars.interlis.ch/ //DEPS ch.interlis:ilivalidator:1.14.1 //DEPS ch.ehi:ehibasics:1.4.1 //DEPS org.apache.camel:camel-bom:4.5.0@pom //DEPS org.apache.camel:camel-main //DEPS org.apache.camel:camel-activemq //DEPS org.apache.camel:camel-debug //DEPS org.apache.camel:camel-file //DEPS org.apache.camel:camel-health //DEPS org.apache.camel:camel-jms import ch.ehi.basics.settings.Settings; import org.interlis2.validator.Validator; import org.apache.camel.main.Main; import org.apache.activemq.ActiveMQConnectionFactory; import org.apache.camel.Exchange; import org.apache.camel.Predicate; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.component.activemq.ActiveMQComponent; import static org.apache.activemq.ActiveMQConnection.DEFAULT_BROKER_URL; import java.nio.file.Paths; import java.util.UUID; public class consume_messages extends RouteBuilder { private static final String TMP_DIR = "/Users/stefan/tmp/"; Main main = new Main(); @Override public void configure() throws Exception { // Kann man sich sparen, falls Default-Url verwendet wird. main.bind("activemq", ActiveMQComponent.activeMQComponent(DEFAULT_BROKER_URL)); main.bind("activemqConnectionFactory", ActiveMQConnectionFactory.class); from("activemq:queue:ch/so/dsbjd/ebau" + "?username=user" + "&password=1234") .setHeader("CamelFileName", method(consume_messages.class, "generateFileName")) .to("file:"+TMP_DIR) .choice() .when(new Predicate() { @Override public boolean matches(Exchange exchange) { Settings settings = new Settings(); settings.setValue(Validator.SETTING_ILIDIRS, ".;"+Validator.SETTING_DEFAULT_ILIDIRS); String fileName = (String) exchange.getIn().getHeader("CamelFileName"); boolean valid = Validator.runValidation(Paths.get(TMP_DIR, fileName).toString(), settings); return valid; } }).process(exchange -> { System.out.println("File is valid and will be imported: " + exchange.getIn().getHeader("CamelFileName")); // ili2pg... }) .otherwise().log("File is NOT valid.") .end(); } public static String generateFileName() { UUID uuid = UUID.randomUUID(); return uuid.toString() + ".xtf"; } }