com.posco.reuse.kafka.activity
Class SFMessageCreate

java.lang.Object
  com.poscoict.glueframework.biz.activity.GlueActivity<GlueContext>
      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>