com.posco.reuse.kafka.activity
Class SFMessageCreate

java.lang.Object
  extended by com.poscoict.glueframework.biz.activity.GlueActivity<GlueContext>
      extended by com.posco.reuse.kafka.activity.SFMessageCreate

public class SFMessageCreate
extends GlueActivity<GlueContext>

avroÇü½ÄÀÇ SFMessageÇüÀÇ °´Ã¼¸¦ »ý¼ºÇÑ´Ù.

 Activity Property
 - result-key: (Çʼö) »ý¼ºµÈ avro µ¥ÀÌÅ͸¦ GlueContext¿¡ µî·ÏÇÏ´Â Key
 - tc-id: (¼±ÅÃ) SFMessage µ¥ÀÌÅÍÀÇ TC-ID °ª
 - keys: (¼±ÅÃ) FMessage µ¥ÀÌÅÍÀÇ keys °ª. ¸®½ºÆ®Çü µ¥ÀÌŸ·Î | ¸¦ ±¸ºÐÀÚ·Î ÀÔ·Â(¿¹: a|b|c) 
 - keys-ctx: (¼±ÅÃ) FMessage µ¥ÀÌÅÍÀÇ keys °ª. GlueContext¿¡ String[] ÇüÀ¸·Î µî·ÏµÇ¾î ÀÖ´Â °æ¿ì ÇØ´ç °´Ã¼ÀÇ Key
 - datas-keys: (¼±ÅÃ) FMessage µ¥ÀÌÅÍÀÇ datas¿¡¼­ MapÀÇ Key °ª. ¸®½ºÆ®Çü µ¥ÀÌŸ·Î | ¸¦ ±¸ºÐÀÚ·Î ÀÔ·Â(¿¹: a|b|c)
 - datas-keys-ctx: (¼±ÅÃ) FMessage µ¥ÀÌÅÍÀÇ datas¿¡¼­ MapÀÇ Key °ª. GlueContext¿¡ String[] ÇüÀ¸·Î µî·ÏµÇ¾î ÀÖ´Â °æ¿ì ÇØ´ç °´Ã¼ÀÇ Key
 - data#(data1,data2...)  : (¼±ÅÃ) FMessage µ¥ÀÌÅÍÀÇ datas¿¡¼­ MapÀÇ value °ª.  Key °ªÀÌ Á¤ÀÇµÈ ¼ø¼­´ë·Î ¸ÊÇÎ
 - data#-ctx(data1-ctx,data2-ctx...) : (¼±ÅÃ) FMessage µ¥ÀÌÅÍÀÇ datas¿¡¼­ MapÀÇ value °ªÀ» °¡Á® ¿Ã GlueContextÀÇ Key.
 - glue-message-convert : (¼±ÅÃ) GlueContextÀÇ GlueMessage¸¦ º¯È¯ÇÏ´Â °æ¿ì ÀÔ·Â(ÀÔ·Â °ª : true)
 
 ¿¹Á¦
 »ç¿ë ¿¹# 1
  <activity name="createMessage01" class="com.posco.reuse.kafka.activity.SFMessageCreate">
   <transition name="success" value="sendMessage"/>
   <property name="keys" value="a|b|c|d|e"/>
   <property name="data1" value="d1|d1-1|d1-2"/>
   <property name="data2" value="d2"/>
   <property name="datas-keys" value="a1|a2|a3|a4"/>
   <property name="data3" value="d3"/>
   <property name="tc-id" value="Test01"/>
   <property name="data4" value="d4"/>
   <property name="result-key" value="sfmessage"/>
  </activity>
 
 »ç¿ë ¿¹# 2
  <activity name="createMessage02" class="com.posco.reuse.kafka.activity.SFMessageCreate">
   <transition name="success" value="sendMessage"/>
   <property name="data1-ctx" value="dc1|dc1-1|dc1-2"/>
   <property name="data2-ctx" value="dc2"/>
   <property name="datas-keys-ctx" value="datakeys"/>
   <property name="data3-ctx" value="dc3"/>
   <property name="data4-ctx" value="dc4"/>
   <property name="tc-id" value="Test02"/>
   <property name="keys-ctx" value="testkeys"/>
   <property name="result-key" value="sfmessage"/>
  </activity>
 
  »ç¿ë ¿¹# 3
  <activity name="createMessage03" class="com.posco.reuse.kafka.activity.SFMessageCreate">
   <transition name="success" value="sendMessage"/>
   <property name="glue-message-convert" value="true"/>
   <property name="result-key" value="sfmessage"/>
  </activity>
 


Field Summary
 
Fields inherited from class com.poscoict.glueframework.biz.activity.GlueActivity
dynamicProperties, logger
 
Constructor Summary
SFMessageCreate()
           
 
Method Summary
 String runActivity(GlueContext ctx)
           
 
Methods inherited from class com.poscoict.glueframework.biz.activity.GlueActivity
commitTransaction, commitTransaction, getDao, getEventList, getName, getProperty, getPropertyNames, getTransition, rollbackTransaction, rollbackTransaction, setEventList, setName, setProperty, setTransition
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

SFMessageCreate

public SFMessageCreate()
Method Detail

runActivity

public String runActivity(GlueContext ctx)
Specified by:
runActivity in class GlueActivity<GlueContext>


Copyright © 2013–2016 POSCO ICT. All rights reserved.