Demo entry 3548863

java

   

Submitted by anonymous on Jan 19, 2016 at 16:58
Language: Java. Code size: 957 Bytes.

// 把一个类标记为@Blocking,那么在配置文件中可以指定timeout, 没有@Blocking这个标记的话,配置文件中的timeout就不会起作用
@Blocking
public class AddressLoader extends BaseWorker {
    private static Log logger = LogFactory.getLog(AddressLoader.class);
 
    // 正常定义需要的成员变量
    private DBConnection connection = DBConnectionPool.getConnection();
 
    // @Input 表示这个变量是当前class执行doAction()方法的输入,当所有标记为@Input的成员变量得到输入值后,才会执行doAction()方法
    @Input(inputVariableId = "name")  // 通过Annotation进行variable binding,外部以name为参数名的输入会自动赋值给myname变量
    protected String myname;
 
    // @Output 表示这个变量在当前class执行doAction()方法完毕后,作为输出,传递给需要这个变量的节点
    @Output(outputVariableId = "address")  // 将myaddress变量绑定到"address"这个id上
    protected String myaddress;
 
    @Override
    public void doAction() {
       // 根据Input变量进行计算,将计算结果赋值给Output变量
        myaddress = loadAddressFromDB(myname);
    }
 
    private String loadAddressFromDB(String name) {
        // 查询数据库
        // 返回相应数据
    }
}

This snippet took 0.00 seconds to highlight.

Back to the Entry List or Home.

Delete this entry (admin only).