albert's blog

2017/12/06

[Java] How to read message from IBM MQ?

Problem
I am using IBM MQ as my queue service.
How to read message (text format) from IBM MQ by Java?

How-To
Here has the sample code:

package com.xxx.mql.service;

import java.io.IOException;
import java.util.Enumeration;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Queue;
import javax.jms.QueueBrowser;
import javax.jms.Session;
import javax.jms.TextMessage;

import org.apache.commons.lang.StringUtils;

import com.fasterxml.jackson.core.JsonProcessingException;
import com.google.common.base.Strings;
import com.ibm.mq.jms.MQQueueConnection;
import com.ibm.mq.jms.MQQueueConnectionFactory;
import com.ibm.mq.jms.MQQueueReceiver;
import com.ibm.mq.jms.MQQueueSession;
import com.tdcc.common.type.MQInfoEnum;
import com.tdcc.mql.utils.MqlUtils;

import lombok.extern.slf4j.Slf4j;

@Slf4j
public class TestMQService {

    private static TestMQService mqServuce;

    private static String mqHost = MQInfoEnum.MQ_HOST.getValue();
    private static String mqChannel = MQInfoEnum.MQ_CHANNEL.getValue();
    private static String mqUser = MQInfoEnum.MQ_USER.getValue();
    private static String mqPwd = "";
    private static String mqQueueMgr = MQInfoEnum.MQ_QUEUEMGR.getValue();

    public static TestMQService getInstance() {
        if (mqServuce == null) {
            mqServuce = new TestMQService();
            return mqServuce;
        } else {
            return mqServuce;
        }
    }

    /**
     * 取得 queue message.
     * 
     * @param queueName
     * @return
     * @throws JMSException
     */
    public String readMessage(String queueName) throws JMSException {
        MQQueueConnectionFactory connFactory = new MQQueueConnectionFactory();
        MQQueueReceiver receiver = null;
        MQQueueSession session = null;
        MQQueueConnection connection = null;
        String message = "";
        try {
            // Config
            connFactory.setHostName(mqHost);
            connFactory.setPort(1414);
            connFactory.setTransportType(1);
            connFactory.setQueueManager(mqQueueMgr);
            connFactory.setChannel(mqChannel);

            connection = (MQQueueConnection) connFactory.createQueueConnection();
            session = (MQQueueSession) connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
            Queue queue = session.createQueue(queueName);
            receiver = (MQQueueReceiver) session.createReceiver(queue);

            connection.start();

            if (receiver != null) {
                Message msg = receiver.receiveNoWait();
                if (msg == null) {
                    message = "";
                } else {
                    if (msg instanceof TextMessage) {
                        TextMessage textMsg = (TextMessage) msg;
                        message = StringUtils.defaultIfBlank(textMsg.getText(), "");
                    } else {
                        String error = "*****不是文字訊息，跳過此筆訊息，class type = " + msg.getClass().toString();
                        log.error(error);
                    }
                }
            }

        } catch (JMSException e) {
            log.error(MqlUtils.toStackTrace(e));
        } finally {
            if (receiver != null) {
                receiver.close();
            }
            if (session != null) {
                session.close();
            }
            if (connection != null) {
                connection.close();
            }
        }
        log.info("[readMessageByJMS] message = " + message);
        return message;
    }
}

2017/12/05

[Java] How to count the number of message in IBM MQ?

Problem
I am using IBM MQ as my queue service.
How to count the number of message in IBM MQ?

How-to
Here has the sample code:

package com.xxx.mql.service;

import java.io.IOException;
import java.util.Enumeration;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Queue;
import javax.jms.QueueBrowser;
import javax.jms.Session;
import javax.jms.TextMessage;

import org.apache.commons.lang.StringUtils;

import com.fasterxml.jackson.core.JsonProcessingException;

import com.google.common.base.Strings;

import com.ibm.mq.jms.MQQueueConnection;
import com.ibm.mq.jms.MQQueueConnectionFactory;
import com.ibm.mq.jms.MQQueueReceiver;
import com.ibm.mq.jms.MQQueueSession;
import com.tdcc.common.type.MQInfoEnum;
import com.tdcc.mql.utils.MqlUtils;

import lombok.extern.slf4j.Slf4j;

@Slf4j
public class TestMQService {

    private static TestMQService mqServuce;

    private static String mqHost = MQInfoEnum.MQ_HOST.getValue();
    private static String mqChannel = MQInfoEnum.MQ_CHANNEL.getValue();
    private static String mqUser = MQInfoEnum.MQ_USER.getValue();
    private static String mqPwd = "";
    private static String mqQueueMgr = MQInfoEnum.MQ_QUEUEMGR.getValue();

    public static TestMQService getInstance() {
        if (mqServuce == null) {
            mqServuce = new TestMQService();
            return mqServuce;
        } else {
            return mqServuce;
        }
    }

    /**
     * 透過 JMS 去查詢 queue 裡面有幾筆訊息.
     * 
     * @param queueName
     * @return
     * @throws JMSException
     */
    public int getNumOfMsg(String queueName) throws JMSException {
        MQQueueConnectionFactory connFactory = new MQQueueConnectionFactory();
        MQQueueReceiver receiver = null;
        MQQueueSession session = null;
        MQQueueConnection connection = null;
        int numOfMsg = 0;
        try {
            // Config
            connFactory.setHostName(mqHost);
            connFactory.setPort(1414);
            connFactory.setTransportType(1);
            connFactory.setQueueManager(mqQueueMgr);
            connFactory.setChannel(mqChannel);

            connection = (MQQueueConnection) connFactory.createQueueConnection();
            session = (MQQueueSession) connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
            Queue queue = session.createQueue(queueName);
            receiver = (MQQueueReceiver) session.createReceiver(queue);

            connection.start();

            QueueBrowser queueBrowser = session.createBrowser((Queue) queue);
            Enumeration msgEnum = queueBrowser.getEnumeration();
            while (msgEnum.hasMoreElements()) {
                Message message = (Message) msgEnum.nextElement();
                numOfMsg++;
            }

        } catch (JMSException e) {
            log.error(MqlUtils.toStackTrace(e));
        } finally {
            if (receiver != null) {
                receiver.close();
            }
            if (session != null) {
                session.close();
            }
            if (connection != null) {
                connection.close();
            }
        }
        log.info("[getNumOfMsgByJMS] numOfMsg = " + numOfMsg);
        return numOfMsg;
    }
}

2017/12/04

Illegal unquoted character ((CTRL-CHAR, code 26)): has to be escaped using backslash to be included in string.

Problem
When I try to convert JSON string to Java bean via Jackson Framework, it throws an exception as bellows:

Illegal unquoted character ((CTRL-CHAR, code 26)): has to be escaped using backslash to be included in string.

The code snippet is:

package albert.practice.json;

import java.io.IOException;

import org.codehaus.jackson.JsonParser.Feature;
import org.codehaus.jackson.annotate.JsonProperty;
import org.codehaus.jackson.map.ObjectMapper;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.ToString;

public class JSONUtils {

    public Response convertJsonToObject(String json) throws IOException {
        ObjectMapper mapper = new ObjectMapper();
        Response response = null;
        try {
            response = mapper.readValue(json, Response.class);
        } catch (IOException e) {
            throw e;
        }
        return response;
    }

    @Data
    @ToString
    @NoArgsConstructor
    @AllArgsConstructor
    public static class Response {
        @JsonProperty("Type")
        private String type;
        @JsonProperty("Status")
        private String status;
    }
}

How-To
Owing to the JSON has some CTRL-CHAR, so Jackson Framework cannot covert to Java bean correctly.
You need to configure OjbectMapper to accept backslash escaping character. The updated code snippet looks like:

package albert.practice.json;

import java.io.IOException;

import org.codehaus.jackson.JsonParser.Feature;
import org.codehaus.jackson.annotate.JsonProperty;
import org.codehaus.jackson.map.ObjectMapper;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.ToString;

public class JSONUtils {

    public Response convertJsonToObject(String json) throws IOException {
        ObjectMapper mapper = new ObjectMapper();
        mapper.configure(Feature.ALLOW_BACKSLASH_ESCAPING_ANY_CHARACTER, true);
        Response response = null;
        try {
            response = mapper.readValue(json, Response.class);
        } catch (IOException e) {
            throw e;
        }
        return response;
    }

    @Data
    @ToString
    @NoArgsConstructor
    @AllArgsConstructor
    public static class Response {
        @JsonProperty("Type")
        private String type;
        @JsonProperty("Status")
        private String status;
    }
}

2017/12/03

[Windows] 執行 Windows Update 發生錯誤的解決方式

有時候在執行 Windows Update 時，會發生莫名的錯誤，如下：

以下是解決方式，步驟如下:

(1) 停止 Windows Update 服務

(2) 刪除以下兩個目錄下的所有檔案

(3) 啟動 Windows Update 服務

(4) 重新檢查更新

2017/12/02

[閱讀筆記] A Gift to My Children - A Father's Lessons for Life and Investing (Jim Rogers)

投資和生活一樣，細節往往是成敗關鍵
股神 Buffett 談投資的時候說了一句名言：「當別人貪婪時恐懼，在別人恐懼時貪婪。」這說的是投資的時機，以及如何跳脫眾人追高殺低的習慣性。這句話更像是一種洞悉世情的人生智慧，不是投資計算的公式
永遠不要做一位排外者，要當一個開放的「世界公民」。日本的「排外」和「失去彈性」，是使日本 1980 年代優勢與競爭力不再的原因
假如周遭的人都勸你不要做某件事，甚至嘲笑你根本不該去做，就可以把這件事當做可能成功的指標。這個道理非常重要，你一定要了解：與眾人反向而行需要勇氣。事實是，這世界從不曾哪個人士靠「從眾」而成功的
你的生活是自己的，不是別人的。別人的忠告當然是有對的時候，但是後證明這些忠告無用的次數卻更多。你必須靠自己研究，你天生就有能力為自己的最大利益下最好的決策。在大多數的情況下，經過自己的思索比違背自己的意願而聽從他人的決定，更能做出正確的決策並採取正確的行動
仔細觀察每個領域的成功者，不論是音樂家、藝術家或是什麼專家，他們之所以成功不是因為模仿別人。有任何人因為看著別人的作為有樣學樣而成功的嗎？
在做你認為是對的事情之前，要盡自己所能的先做好功課。找出任何可以到手的資料，仔細研究，徹底分析，直到完全確定你的想法是正確的。絕對不要再還沒有研究之前採取任何行動。你會發現，那些不成功的人通常是沒有花時間研究就貿然涉入一個他們不了解的東西，更糟的是，他們拒絕學習，結果賠上了寶貴的時間與金錢
當你發現有一件事是你感興趣的，別讓年齡羈絆你，去做就是了
在一個國家還有問題、尚未穩定下來時就前往投資，會得到巨大的報酬，但這唯有在看得見正向的改革即將來臨時才可以為之
當每個人的想法一致時，就表示根本沒有人在用大腦
很多社會大眾相信的東西，常常是錯的
那些投資失敗的人，正是那些連財務報告都沒讀完的人，因為他們沒看到投資成功和充分資訊之間的關聯性
開放心胸，永遠不要拒絕第一眼看上去和你不一樣的人
大宗物資或大宗商品，指的是可大量生產種植或提煉的原物料，目前在全球交易的原物料高達百種以上，大致可區分為四大類別：原油、天然氣等能源類，金、銀、銅、鉑等貴金屬類，小麥、玉米等榖物類，以及蠶絲、棉花等纖維類
如果你想使你自己和你的國家變得更好，偏見、歧視及不接納他人等，對你一點好處都沒有
每個人都必須獨立思考，不可依賴他人
一般而言，有兩種方法可以檢視一件事：一種方法是從觀察中得到結論，另外一種方法是從邏輯中找到真相
思考有兩種方法：一個叫做歸納法（induction），從某個特定結論開始導出比較一般性的看法；另一個則是演繹法（deduction），從一般的證據開始導出某個特定真相。這兩種方法並沒有哪種比較好，重點在於訓練自己可以應用這兩種邏輯方法，使你能有一個平衡的思考方式並見微知著
一個國家所發生的大事，不只影響到華爾街，也會對全球原物料和股票價格、甚至整個世界造成影響。歷史一再告訴我們，戰爭和政治的不穩定可以始源物料的價格上揚，金價也絕對會隨之上升。一場大規模的戰爭不但會驅使金價上揚，幾乎所有的原物料也會跟著變貴
歷史通常會自我重複，人性不會改變。以前發生過的事，以後還是會再發生
不要讓沉沒成本（sink cost）影響你的決定，意思是說不論你已經投資了多少時間、金錢、精力，假如真的行不通，就不要再為了回收這些你曾經付出的而繼續試下去
當別人都在說賣的時候，要說「買」真的很困難
即使那些自稱是「專業人士」的人，有時候也會受到烏合之眾（mob psychology）心理的影響。許多專家都在 dot com 風暴中損失慘重
去檢查事實，客觀的評估真正的情況，不要被眾人的共同意見所迷惑，讓人牽著走。你需要知道何時把自己與眾人分離，獨立的思考
情緒會驅使股票市場走向某一個方向。當大眾對某則新聞反應過度時，他們不是高價買入，就是在不對的時機賣空。很多時候，投資人的心理會加速市場走向
想知道未來可能會發生什麼事，你必須先知道目前世界上發生的各種改變。這個世界是變動不居的，你眼前的功課是找出一個方法處理這些改變。那些不願意承認改變的未來、不肯接受改變的人會被時代淘汰，而得益的是那些能看出改變、擁抱改變的人
不論你的觀點如何，不接受改變就像逆流而游，與這股力量對抗的你，遲早要滅頂的
把你的眼光放在未來，不要眷戀那些遲早會過時的東西。不管你曾經投入多少的時間、精力和金錢，一旦這個東西過時了，它就永遠消失了。把堵住押在你知道它會長存的東西上面，那些看得見未來的人可以累積財富
假如你有借錢，永遠要準時還錢，盡可能一有錢就還掉借款。好的信用非常重要，壞信用會如鬼魅，經年糾纏著你
不論什麼時候，只要你感覺自己無所不能時，停下來，什麼事都不要做，坐下來休息一下，克服感染你的烏合之眾心理。永遠用冷靜、理性的態度看待真實世界，你會打造出屬於自己未來的成功。當你可以說服自己，你的思考是有效度的、合理的時候，就是你開始行動的時機
假如你想成功，絕對不能忽略你應該好好準備。我所做的成功投資，都是因為是先花時間盡可能的蒐集資訊，詳細研讀每個細節。假如你涉入自己不懂的事物，那你永遠不會成功。假如你對自己不了解的東西下注，這不是投資，這叫賭博
永遠買高品質的東西，他們經久耐用，更能保持價值
無知源於扭曲的妄尊自大感，千萬不要讓你自己變得自大。用功讀書，學得越多你才知道你懂得越少，懷抱著謙虛，才能跳脫出自傲與自滿，才不會失去洞見真相的能力

2017/12/01

[閱讀筆記] Common Stocks and Uncommon Profits (4/4)

我的投資哲學：

買進的公司必須對於長期獲利成長有想法、有計畫，如此一來 newcomer 將難以分享其成長的果實
聚焦於那些因為整體市場條件或被市場嚴重低估的公司，若確認其為一家好公司，大膽買進它
不要因為預測經濟變壞或股票市場變壞，就賣出股票，因為未來太難預測。只有兩種狀況，我會建議將股票賣出：(1) 企業本質已經改變時 (如經營者已經換人，而且換的人比以前差勁；公司在成長，企業的經營者卻沒有跟著成長時)；(2) 企業的成長速度已經比整體經濟成長速度還要慢時
分配高股利的公司，未必是值得投資的好公司；反倒是低股利的公司，你比較容易從中找到好的投資機會
投資難免失利，要盡速承認錯誤，了解其原因，並從中學到經驗避免重複犯錯，才是一個好的投資管理
對個人投資來說，分散投資很重要，但是不要過度分散，持有種類至多10~12種，會是比較適當的數字
不要聽信投顧的、社會大眾的說法。你應該多加學習、強化自己的判斷能力，當你發現你判斷的方向與群眾不同時，你要有勇氣走自己的路
成功的投資在於努力、智慧與正直

評估一家公司是否是有前景的公司的幾個關鍵因素

Functional Factors

相較於競爭者，公司必須在產生服務與產品的過程中，具備成本優勢，而且必須能持續維持此優勢：較低的成本代表著比較快達到損益兩平，較容易在市場蕭條時存活下來，比較容易將較弱的競爭者逼出市場；較低的成本代表擁有較高的毛利率，可以賺到更多的錢投入研發，維持其競爭力
公司對於客戶需求的改變要有強烈的敏銳度，並應該改變快速地提供客戶想要的產品與服務
有效的行銷需要的不只是了解客戶需要什麼，還要用客戶的語言告訴他們，讓客戶了解此產品或服務好在哪裡，為什麼需要它
無論是否是高科技公司，都須要有具備強大的且有良好領導的研發能力：如此才能產生更新、更好的產品，提供更有效率或效果的服務
擁有有效率的研發：其有兩個重要的元素，(1) 市場與利潤的了解；(2) 領導與管理人才庫成為有效率的工作團隊的能力
擁有強大的財務團隊：其優點包括 (1) 能掌握精確的成本資訊，協助管理團隊將精力與時間，花在對獲利貢獻最多的產品上；(2) 成本計算系統可以找出在生產、行銷、研發中叫無效率的地方；(3) 省下來的成本，可以投入資本支出
擁有一個能提供對於公司獲利可能產生威脅的早期預警系統，讓公司可以提早產生矯正計畫，將可能發生的風險最小化

People Factors

企業需要有具備堅定的企業家性格的領導者，產生原生的想法，建立公司的未來
一位追求成長的CEO，身邊必須有稱職的團隊，並被授予權限來執行公司的事務，團隊合作是非常重要的
訓練基層的員工來負更大的責任，高階主管的繼任者應該要從內部的人才庫挑選，從公司外部找繼任者，會是一個警訊
企業家精神必須滲透到整個組織
越成功的企業通常越有其獨特的特質，這是一個正面的訊號
管理者必須體認與了解，這個世界一直已比過去更快的速度在改變：每個視為理所當然的做事方式，都必須定期重新檢視，看有無新的、較好的方式；做事、管理方式的改變都會帶來風險，這些都要被指認出並將其產生的影響最小化
無論是哪個層級的員工，都認為他們的公司是個工作的好地方
主管應該樂於提高為了健全成長所需的員工訓練。成長需要犧牲一些現有的利益，做為未來成長的基石

Business Characteristics

利潤與銷售的比率雖然重要，但是員工的離職率或許是用來判斷你的投資是否安全的更好的指標。若看到報導說此家公司擁有高離職率，那就是一個警訊
高毛利會吸引新的進入者來競爭，競爭會侵蝕利潤。最好的方式是提升運作效率、降低生產成本，讓其他人毫無誘因來跟你競爭
經營良好、位居產業領導位置的公司，通常會建立起強大的競爭力，也會吸引投資人的目光
能夠當第一個推出新產品的公司
產品間並非孤島。在消費者的荷包中，產品間是間接競爭的關係。若產品價格改變，很有可能會只買A、放棄B，有些產品可能會失去吸引力，即便是管理良好、低成本的公司也不例外
要導入新的、更高品質的產品到現有的市場非常困難。創新者一定要想辦法有新的作法或融合各種技術，才能提升成功的機會
一個理想的投資標的是，公司已經在市場建立起領先的地位，並且有強大的能力進行防禦阻絕新的競爭者

Total Pageviews

2017/12/06

[Java] How to read message from IBM MQ?

2017/12/05

[Java] How to count the number of message in IBM MQ?

2017/12/04

Illegal unquoted character ((CTRL-CHAR, code 26)): has to be escaped using backslash to be included in string.

2017/12/03

[Windows] 執行 Windows Update 發生錯誤的解決方式

2017/12/02

[閱讀筆記] A Gift to My Children - A Father's Lessons for Life and Investing (Jim Rogers)

2017/12/01

[閱讀筆記] Common Stocks and Uncommon Profits (4/4)