|
|||||||||
ÀüÀÇ Å¬·¡½º ´ÙÀ½ÀÇ Å¬·¡½º | ÇÁ·¹ÀÓ ÀÖ¾î ÇÁ·¹ÀÓ ¾øÀ½ | ||||||||
°³¿ä: ³»ºÎ Ŭ·¡½º | Çʵå | constructor¡¡ ¡¡ | ¸Þ¼Òµå | »ó¼¼: Çʵå | constructor¡¡ ¡¡ | ¸Þ¼Òµå |
Ŭ¶óÀÌ¾ðÆ®´Â,MessageConsumer
¿ÀºêÁ§Æ®¸¦ »ç¿ëÇØ ¸ñÀûÁö·ÎºÎÅÍ ¸Þ¼¼Áö¸¦ ¼ö½ÅÇÕ´Ï´Ù. MessageConsumer
¿ÀºêÁ§Æ®´Â,Destination
¿ÀºêÁ§Æ®¸¦, ¼¼¼Ç¿¡ ÀÇÇØ Á¦°øµÇ´Â ¸Þ¼¼Áö ÄÁ½´¸Ó(consumer) ÀÛ¼º ¸Þ¼Òµå¿¡ °Ç³×ÁÖ´Â °ÍÀ¸·Î ÀÛ¼ºµË´Ï´Ù.
MessageConsumer
´Â, ¸ðµç ¸Þ¼¼Áö ÄÁ½´¸Ó(consumer)ÀÇ Ä£ÀÎÅÍÆäÀ̽ºÀÔ´Ï´Ù.
¸Þ¼¼Áö ÄÁ½´¸Ó(consumer)´Â, ¸Þ¼¼Áö ½Ç·ºÅ͸¦ »ç¿ëÇØ ÀÛ¼ºÇÒ ¼ö ÀÖ½À´Ï´Ù. Ŭ¶óÀÌ¾ðÆ®´Â, ¸Þ¼¼Áö ½Ç·ºÅ͸¦ »ç¿ëÇÏ´Â °ÍÀ¸·Î½á, ¸Þ¼¼Áö ÄÁ½´¸Ó(consumer)¿¡°Ô Àü´ÞµÇ´Â ¸Þ¼¼Áö¸¦ ½Ç·ºÅÍ¿¡ ÀÏÄ¡ÇÏ´Â ¸Þ¼¼Áö·Î ÇÑÁ¤ÇÒ ¼ö ÀÖ½À´Ï´Ù.
Ŭ¶óÀÌ¾ðÆ®´Â, ¸Þ¼¼Áö ÄÁ½´¸Ó(consumer)ÀÇ ¸Þ¼¼Áö¸¦ µ¿±âÀûÀ¸·Î ¼ö½ÅÇÏ´Â Àϵµ, ¸Þ¼¼Áö Âø½Å½Ã¿¡ ÄÁ½´¸Ó(consumer)·ÎºÎÅÍ ºñµ¿±âÀûÀ¸·Î Àü´Þ½Ãų ¼öµµ ÀÖ½À´Ï´Ù.
µ¿±âÀûÀÎ ¼ö½ÅÀÇ °æ¿ì, Ŭ¶óÀÌ¾ðÆ®´Â receive
¸Þ¼ÒµåÀÇ ¾î´ÀÂÊÀ̵çÀ» »ç¿ëÇØ, ¸Þ¼¼Áö ÄÁ½´¸Ó(consumer)·ÎºÎÅÍÀÇ ´ÙÀ½ÀÇ ¸Þ¼¼Áö¸¦ ¿ä±¸ÇÒ ¼ö ÀÖ½À´Ï´Ù. receive
¸Þ¼Òµå¿¡´Â ¸î°³ÀÇ Á¾·ù°¡ ÀÖ¾î, Ŭ¶óÀÌ¾ðÆ®´Â À̰͵éÀ» »ç¿ëÇØ ´ÙÀ½ÀÇ ¸Þ¼¼ÁöÀÇ Æú¸µ ¶Ç´Â ´ë±â¸¦ ½ÇÇàÇÒ ¼ö ÀÖ½À´Ï´Ù.
ºñµ¿±â Àü´ÞÀÇ °æ¿ì, Ŭ¶óÀÌ¾ðÆ®´Â MessageListener
¿ÀºêÁ§Æ®¸¦ ¸Þ¼¼Áö ÄÁ½´¸Ó(consumer)¿¡°Ô µî·ÏÇÒ ¼ö ÀÖ½À´Ï´Ù. ¸Þ¼¼Áö°¡ ¸Þ¼¼Áö ÄÁ½´¸Ó(consumer)¿¡°Ô µµÂøÇϸé(ÀÚ),MessageListener
ÀÇ onMessage
¸Þ¼Òµå°¡ ºÒ·Á °¡, ¸Þ¼¼Áö°¡ Àü´ÞµË´Ï´Ù.
MessageListener
°¡ ¿¹¿Ü¸¦ ½½·Î¿ì ÇÏ´Â °æ¿ì, Ŭ¶óÀ̾ðÆ®ÀÇ ÇÁ·Î±×·¡¹Ö ¿¡·¯°¡ ¿øÀÎÀÔ´Ï´Ù.
QueueReceiver
,
TopicSubscriber
,
Session
¸Þ¼ÒµåÀÇ °³¿ä | |
void |
close ()
¸Þ¼¼Áö ÄÁ½´¸Ó(consumer)¸¦ ´Ý½À´Ï´Ù. |
MessageListener |
getMessageListener ()
ÀÌ ¸Þ¼¼Áö ÄÁ½´¸Ó(consumer)ÀÇ MessageListener ¸¦ ÃëµæÇÕ´Ï´Ù. |
java.lang.String |
getMessageSelector ()
ÀÌ ¸Þ¼¼Áö ÄÁ½´¸Ó(consumer)ÀÇ ¸Þ¼¼Áö ½Ç·ºÅͽÄÀ» ÃëµæÇÕ´Ï´Ù. |
Message |
receive ()
ÀÌ ¸Þ¼¼Áö ÄÁ½´¸Ó(consumer)¿ëÀ¸·Î »ý¼ºµÈ ´ÙÀ½ÀÇ ¸Þ¼¼Áö¸¦ ¼ö½ÅÇÕ´Ï´Ù. |
Message |
receive (long timeout)
ÁöÁ¤µÈ ŸÀÓ ¾Æ¿ô °£°Ý³»¿¡ µµÂøÇÏ´Â ´ÙÀ½ÀÇ ¸Þ¼¼Áö¸¦ ¼ö½ÅÇÕ´Ï´Ù. |
Message |
receiveNoWait ()
°ð¹Ù·Î ¼ö½Å °¡´ÉÇÑ °æ¿ì´Â, ´ÙÀ½ÀÇ ¸Þ¼¼Áö¸¦ ¼ö½ÅÇÕ´Ï´Ù. |
void |
setMessageListener (MessageListener listener)
ÀÌ ¸Þ¼¼Áö ÄÁ½´¸Ó(consumer)ÀÇ MessageListener ¸¦ ¼³Á¤ÇÕ´Ï´Ù.
|
¸Þ¼ÒµåÀÇ »ó¼¼ |
public java.lang.String getMessageSelector() throws JMSException
JMSException
- ³»ºÎ ¿¡·¯¸¦ À§Çؼ(¶§¹®¿¡) JMS ÇÁ·Î¹ÙÀÌ´õ°¡ ¸Þ¼¼Áö ½Ç·ºÅÍÀÇ Ãëµæ¿¡ ½ÇÆÐÇßÀ» °æ¿ìpublic MessageListener getMessageListener() throws JMSException
MessageListener
¸¦ ÃëµæÇÕ´Ï´Ù. JMSException
- ³»ºÎ ¿¡·¯¸¦ À§Çؼ(¶§¹®¿¡) JMS ÇÁ·Î¹ÙÀÌ´õ°¡ ¸Þ¼¼Áö ûÃëÀÚÀÇ Ãëµæ¿¡ ½ÇÆÐÇßÀ» °æ¿ìsetMessageListener(javax.jms.MessageListener)
public void setMessageListener(MessageListener listener) throws JMSException
MessageListener
¸¦ ¼³Á¤ÇÕ´Ï´Ù.
¸Þ¼¼Áö ûÃëÀÚ¸¦ null ·Î ¼³Á¤ÇÏ´Â °ÍÀº, ¸Þ¼¼Áö ÄÁ½´¸Ó(consumer)¿ëÀÇ ¸Þ¼¼Áö ûÃëÀÚÀÇ ¼³Á¤À» ÇØÁ¦ÇÏ´Â °ÍÀ¸·Î µî°¡ÀÔ´Ï´Ù.
±âÁ¸ÀÇ Ã»ÃëÀÚ¿¡ ÀÇÇØ ¸Þ¼¼Áö°¡ 󸮵ǰí ÀÖ´Â µ¿¾È, ¶Ç´Â ÄÁ½´¸Ó(consumer)¸¦ »ç¿ëÇØ ¸Þ¼¼ÁöÀÇ µ¿±âÀûÀΠ󸮸¦ Çϰí ÀÖ´Â µ¿¾È¿¡,MessageConsumer.setMessageListener
¸¦ È£ÃâÇßÀ» °æ¿ìÀÇ ¿µÇâ¿¡ ´ëÇØ¼´Â Á¤Àǵǰí ÀÖÁö ¾Ê½À´Ï´Ù.
listener
- ¸Þ¼¼Áö Àü´ÞóÀÇ Ã»ÃëÀÚJMSException
- ³»ºÎ ¿¡·¯¸¦ À§Çؼ(¶§¹®¿¡) JMS ÇÁ·Î¹ÙÀÌ´õ°¡ ¸Þ¼¼Áö ûÃëÀÚÀÇ ¼³Á¤¿¡ ½ÇÆÐÇßÀ» °æ¿ìgetMessageListener()
public Message receive() throws JMSException
¸Þ¼¼Áö°¡ »ý¼ºµÇ´ÂÁö, ÀÌ ¸Þ¼¼Áö ÄÁ½´¸Ó(consumer)°¡ ´ÝÇôÁú ¶§±îÁö, ÀÌ È£ÃâÀº ºí·ÏÀ» ½ÇÇàÇÕ´Ï´Ù.
Æ®·£Àè¼Ç(transaction) ³»ºÎ¿¡¼ ÀÌ receive
°¡ ½ÇÇàµÇ´Â °æ¿ì, ÄÁ½´¸Ó(consumer)´Â Æ®·£Àè¼Ç(transaction)°¡ À§Å¹µÉ ¶§±îÁö ¸Þ¼¼Áö¸¦ º¸°ü À¯ÁöÇÕ´Ï´Ù.
JMSException
- ³»ºÎ ¿¡·¯¸¦ À§Çؼ(¶§¹®¿¡) JMS ÇÁ·Î¹ÙÀÌ´õ°¡ ´ÙÀ½ÀÇ ¸Þ¼¼ÁöÀÇ ¼ö½Å¿¡ ½ÇÆÐÇßÀ» °æ¿ìpublic Message receive(long timeout) throws JMSException
¸Þ¼¼Áö°¡ µµÂøÇÏ´ÂÁö, ŸÀÓ ¾Æ¿ô¿¡ ÀÇÇØ, À¯È¿±â°£ Á¶°¢ÀÌ µÇ´ÂÁö, ÀÌ ¸Þ¼¼Áö ÄÁ½´¸Ó(consumer)°¡ ´ÝÇôÁú ¶§±îÁö, ÀÌ È£ÃâÀº ºí·ÏÀ» ½ÇÇàÇÕ´Ï´Ù. timeout
¸¦ Á¦·Î·Î ¼³Á¤Çϸé(ÀÚ) À¯È¿±â°£ Á¶°¢ÀÌ µÉ °ÍÀº ¾ø±â ¶§¹®¿¡, ÀÌ È£ÃâÀº ºí·ÏÀ» ¹«±âÇÑÀ¸·Î ½ÇÇàÇÕ´Ï´Ù.
timeout
- ŸÀÓ ¾Æ¿ôÄ¡ (¹Ð¸® ¼¼ÄÁµå)JMSException
- ³»ºÎ ¿¡·¯¸¦ À§Çؼ(¶§¹®¿¡) JMS ÇÁ·Î¹ÙÀÌ´õ°¡ ´ÙÀ½ÀÇ ¸Þ¼¼ÁöÀÇ ¼ö½Å¿¡ ½ÇÆÐÇßÀ» °æ¿ìpublic Message receiveNoWait() throws JMSException
JMSException
- ³»ºÎ ¿¡·¯¸¦ À§Çؼ(¶§¹®¿¡) JMS ÇÁ·Î¹ÙÀÌ´õ°¡ ´ÙÀ½ÀÇ ¸Þ¼¼ÁöÀÇ ¼ö½Å¿¡ ½ÇÆÐÇßÀ» °æ¿ìpublic void close() throws JMSException
ÇÁ·Î¹ÙÀÌ´õ´Â MessageConsumer
¿¡ ´ëÀÀÇÏ´Â ¸®¼Ò½º¸¦ Java °¡»ó ¸Ó½Å ¿ÜºÎ¿¡ ÇÒ´çÇÏ´Â °æ¿ì°¡ ÀÖ±â (À§ÇØ)¶§¹®¿¡, ÀÌ·¯ÇÑ ¸®¼Ò½º°¡ ºÒÇÊ¿äÇÏ°Ô µÇ¾úÀ» °æ¿ì, Ŭ¶óÀÌ¾ðÆ®°¡ ¸®¼Ò½º¸¦ ´ÝÀ» Çʿ䰡 ÀÖ½À´Ï´Ù. ÀÌ·¯ÇÑ ¸®¼Ò½ºÀÇ ÀçÀÌ¿ëÀ» °¡º£Áö ÄÝ·º¼Ç¿¡ ¸Ã°åÀ» °æ¿ì, ÀûÀýÇÑ Å¸Àֿ̹¡ ÀçÀÌ¿ëÀ» ÇÑ´Ù°í´Â ÇÒ ¼ö ¾ø½À´Ï´Ù.
receive
¶Ç´Â ½ÇÇàÁßÀÇ ¸Þ¼¼Áö ûÃëÀÚ°¡ ¿Ï·áÇÒ ¶§±îÁö, ÀÌ È£ÃâÀº ºí·ÏÀ» ½ÇÇàÇÕ´Ï´Ù. ÀÌ ¸Þ¼¼Áö ÄÁ½´¸Ó(consumer)°¡ ´ÝÇôÁö¸é(ÀÚ), ºí·Ï µÈ ¸Þ¼¼Áö ÄÁ½´¸Ó(consumer)ÀÇ receive
È£ÃâÀÌ null ¸¦ µ¹·ÁÁÝ´Ï´Ù.
JMSException
- ³»ºÎ ¿¡·¯¸¦ À§Çؼ(¶§¹®¿¡) JMS ÇÁ·Î¹ÙÀÌ´õ°¡ ÄÁ½´¸Ó(consumer)¸¦ ´Ý´Â 󸮿¡ ½ÇÆÐÇßÀ» °æ¿ì
|
|||||||||
ÀüÀÇ Å¬·¡½º ´ÙÀ½ÀÇ Å¬·¡½º | ÇÁ·¹ÀÓ ÀÖ¾î ÇÁ·¹ÀÓ ¾øÀ½ | ||||||||
°³¿ä: ³»ºÎ Ŭ·¡½º | Çʵå | constructor¡¡ ¡¡ | ¸Þ¼Òµå | »ó¼¼: Çʵå | constructor¡¡ ¡¡ | ¸Þ¼Òµå |