|
|||||||||
ÀüÀÇ Å¬·¡½º ´ÙÀ½ÀÇ Å¬·¡½º | ÇÁ·¹ÀÓ ÀÖ¾î ÇÁ·¹ÀÓ ¾øÀ½ | ||||||||
°³¿ä: ³»ºÎ Ŭ·¡½º | Çʵå | constructor¡¡ ¡¡ | ¸Þ¼Òµå | »ó¼¼: Çʵå | constructor¡¡ ¡¡ | ¸Þ¼Òµå |
Ŭ¶óÀÌ¾ðÆ®´Â,TopicSubscriber
¿ÀºêÁ§Æ®¸¦ »ç¿ëÇØ ÅäÇÈ¿¡ ÆÄºê¸´½´ µÈ ¸Þ¼¼Áö¸¦ ¼ö½ÅÇÕ´Ï´Ù. TopicSubscriber
¿ÀºêÁ§Æ®´Â, ¸Þ¼¼Áö ÄÁ½´¸Ó(consumer)ÀÇ ÆÄºê¸´½´/»çºê½ºÅ©¶óÀ̺ê Çü½ÄÀÔ´Ï´Ù.
TopicSession
¸¦ »ç¿ëÇϸé(ÀÚ), ÅäÇÈ ¸¶´Ù º¹¼öÀÇ TopicSubscriber
¿ÀºêÁ§Æ®¸¦ ÀÛ¼ºÇÒ ¼ö ÀÖ½À´Ï´Ù. TopicSession
´Â, ÅäÇÈ¿ëÀÇ °¢ ¸Þ¼¼Áö¸¦ ¼ö½Å ´ë»óÀÇ °¢ »çºê½ºÅ©¶óÀ̹ٿ¡ Àü´ÞÇÕ´Ï´Ù. ¸Þ¼¼ÁöÀÇ °¢ Ä«ÇÇ´Â, ¿ÏÀüÇÏ°Ô º°°³ÀÇ ¸Þ¼¼Áö·Î¼ 󸮵˴ϴÙ. 1 °³ÀÇ Ä«ÇÇ¿¡ ´ëÇØ¼ ½ÇÇàµÇ´Â ÀÛ¾÷ÀÌ, ±× ¹Û¿¡ ¿µÇâÀ» ÁÙ °ÍÀº ¾ø½À´Ï´Ù. ¾î´À ¸Þ¼¼Áö¸¦ È®ÀÎ ÀÀ´äÇÏ´Â °ÍÀ¸·Î, ´Ù¸¥ ¸Þ¼¼Áö°¡ È®ÀÎ ÀÀ´äµÉ °ÍÀº ¾ø½À´Ï´Ù. ¾î´À ¸Þ¼¼Áö¸¦ Áï¼®¿¡¼ Àü´ÞÇØ, »çºê½ºÅ©¶óÀٰ̹¡ ÀÌÀüÀÇ ¸Þ¼¼Áö¸¦ ó¸®ÇÒ ¶§±îÁö ´Ù¸¥ ¸Þ¼¼ÁöÀÇ Àü´ÞÀ» ´ë±â½ÃŰ´Â °ÍÀÌ °¡´ÉÇÕ´Ï´Ù.
Åë»óÀÇ TopicSubscriber
¿ÀºêÁ§Æ®´Â, Áö¼Ó¼ºÀÌ ¾ø½À´Ï´Ù. ÀÌ·¯ÇÑ ¿ÀºêÁ§Æ®´Â, ¾×ƼºêÇÑ µ¿¾È¿¡ ÆÄºê¸´½´ µÇ´Â ¸Þ¼¼Áö¸¸À» ¼ö½ÅÇÕ´Ï´Ù.
»çºê½ºÅ©¶óÀ̹ÙÀÇ ¸Þ¼¼Áö ½Ç·ºÅÍ¿¡ ÀÇÇØ ÇÊÅÍ Ã³¸®µÈ ¸Þ¼¼Áö°¡, »çºê½ºÅ©¶óÀ̹ٿ¡ Àü´ÞµÉ °ÍÀº ¾ø½À´Ï´Ù. »çºê½ºÅ©¶óÀ̹ٷκÎÅÍ º¸¸é(ÀÚ), ÀÌ·¯ÇÑ ¸Þ¼¼Áö´Â Á¸ÀçÇÏÁö ¾Ê½À´Ï´Ù.
Á¢¼ÓÀÌ, ÅäÇÈÀÇ ÆÄºê¸´½´¿Í »çºê½ºÅ©¶óÀ̺êÀÇ ¾çÂÊ ¸ðµÎ¸¦ ½ÇÇàÇÏ´Â °æ¿ì°¡ ÀÖ½À´Ï´Ù. »çºê½ºÅ©¶óÀ̹ٴÂ,NoLocal
¼Ó¼ºÀ» »ç¿ëÇØ, µ¶ÀÚÀûÀÎ Á¢¼Ó¿¡ ÀÇÇØ ÆÄºê¸´½´ µÈ ¸Þ¼¼ÁöÀÇ Àü´ÞÀ» ±ÝÁöÇÒ ¼ö ÀÖ½À´Ï´Ù.
ÅäÇÈ¿¡ ´ëÇØ¼ ÆÄºê¸´½´ µÈ ¸ðµç ¸Þ¼¼Áö (»çºê½ºÅ©¶óÀٰ̹¡ ¾×ƼºêÇÏÁö ¾ÊÀº »óÅ·ΠÆÄºê¸´½´ µÈ ¸Þ¼¼Áö¸¦ Æ÷ÇÔÇÑ´Ù)¸¦ Ŭ¶óÀÌ¾ðÆ®°¡ ¼ö½ÅÇÒ Çʿ䰡 ÀÖ´Â °æ¿ì, Áö¼Ó¼ºÀÌ ÀÖ´Â TopicSubscriber
°¡ »ç¿ëµË´Ï´Ù. JMS ÇÁ·Î¹ÙÀÌ´õ´Â, ÀÌ Áö¼Ó¼ºÀÌ ÀÖ´Â ¿¹¾à ±¸µ¶ÀÇ ±â·ÏÀ» º¸°ü À¯ÁöÇØ, ÀÌ Áö¼Ó¼º »çºê½ºÅ©¶óÀ̹ٿ¡ ÀÇÇØ È®ÀÎ ÀÀ´äµÇ´ÂÁö, ±âÇÑ ¸¶°¨ÀÌ µÉ ¶§±îÁö ÅäÇÈÀÇ ÆÄºê¸´»þ·ÎºÎÅÍÀÇ ¸Þ¼¼Áö ¸ðµç °ÍÀÌ È®½ÇÈ÷ º¸°ü À¯ÁöµÇµµ·Ï(µíÀÌ) ÇÕ´Ï´Ù.
Áö¼Ó¼º »çºê½ºÅ©¶óÀ̹ٸ¦ º¸°ü À¯ÁöÇÏ´Â ¼¼¼ÇÀº, Ç×»ó µ¿ÀÏÇÑ Å¬¶óÀÌ¾ðÆ® ½Äº°ÀÚ¸¦ Á¦°øÇÒ Çʿ䰡 ÀÖ½À´Ï´Ù. ¶Ç, °¢ Ŭ¶óÀÌ¾ðÆ®´Â, ÀÛ¼ºÇÏ´Â Áö¼Ó¼ºÀÌ ÀÖ´Â °¢ ¿¹¾à ±¸µ¶À» ÀÏÀÇ¿¡ ½Äº°ÇÏ´Â À̸§À» (Ŭ¶óÀÌ¾ðÆ® ½Äº°ÀÚ³»¿¡¼) ÁöÁ¤ÇÒ Çʿ䰡 ÀÖ½À´Ï´Ù. Áö¼Ó¼ºÀÌ Àִ ƯÁ¤ÀÇ ¿¹¾à ±¸µ¶¿ëÀÇ TopicSubscriber
¸¦ º¸°ü À¯ÁöÇÒ ¼ö ÀÖ´Â °ÍÀº, ÇÑ ¹ø¿¡ 1 °³ÀÇ ¼¼¼Ç »ÓÀÔ´Ï´Ù.
Ŭ¶óÀÌ¾ðÆ®´Â, Áö¼Ó¼ºÀÌ ÀÖ´Â µ¿¸íÀÇ TopicSubscriber
¸¦ ÀÛ¼ºÇØ, ÅäÇÈÀ̳ª ¸Þ¼¼Áö ½Ç·ºÅ͸¦ »õ·Ó°Ô ÀÛ¼ºÇÏ´Â °ÍÀ¸·Î½á, Áö¼Ó¼ºÀÌ ÀÖ´Â ±âÁ¸ÀÇ ¿¹¾à ±¸µ¶À» º¯°æÇÒ ¼ö ÀÖ½À´Ï´Ù. Áö¼Ó¼º ¿¹¾à ±¸µ¶À» º¯°æÇÏ´Â °ÍÀº, ÀÌÀüÀÇ ¿¹¾à ±¸µ¶À» ÇØÁ¦ (»èÁ¦)ÇØ »õ·Î¿î ¿¹¾à ±¸µ¶À» ÀÛ¼ºÇÏ´Â °ÍÀ¸·Î µî°¡ÀÔ´Ï´Ù.
TopicSession
´Â, Ŭ¶óÀÌ¾ðÆ®¿¡ ÀÇÇØ ÀÛ¼ºµÈ Áö¼Ó¼º ¿¹¾à ±¸µ¶À» »èÁ¦Çϱâ À§ÇÑ unsubscribe
¸Þ¼Òµå¸¦ Á¦°øÇÕ´Ï´Ù. ÀÌ ¸Þ¼Òµå´Â, »çºê½ºÅ©¶óÀ̹ٿ¡ ´ë½ÅÇØ ÇÁ·Î¹ÙÀÌ´õ°¡ À¯ÁöÇϰí ÀÖ´Â »óŸ¦ »èÁ¦ÇÕ´Ï´Ù.
TopicSession
,
TopicSession.createSubscriber(Topic)
,
TopicSession.createSubscriber(Topic, String, boolean)
,
TopicSession.createDurableSubscriber(Topic, String)
,
TopicSession.createDurableSubscriber(Topic, String, String, boolean)
,
MessageConsumer
¸Þ¼ÒµåÀÇ °³¿ä | |
boolean |
getNoLocal ()
ÀÌ »çºê½ºÅ©¶óÀ̹ٿëÀÇ NoLocal ¼Ó¼ºÀ» ÃëµæÇÕ´Ï´Ù. |
Topic |
getTopic ()
ÀÌ »çºê½ºÅ©¶óÀ̹ٿ¡ °ü·ÃÁöÀ» ¼ö ÀÖ¾ú´ø Topic ¸¦ ÃëµæÇÕ´Ï´Ù. |
ÀÎÅÍÆäÀ̽º javax.jms. MessageConsumer ·ÎºÎÅÍ °è½ÂÇÑ ¸Þ¼Òµå |
close , getMessageListener , getMessageSelector , receive , receive , receiveNoWait , setMessageListener |
¸Þ¼ÒµåÀÇ »ó¼¼ |
public Topic getTopic() throws JMSException
Topic
¸¦ ÃëµæÇÕ´Ï´Ù. Topic
JMSException
- ³»ºÎ ¿¡·¯¸¦ À§Çؼ(¶§¹®¿¡) JMS ÇÁ·Î¹ÙÀÌ´õ°¡ ÀÌ Æ®ÇÈÅ©»çºê½ºÅ©¶óÀ̹ٿëÀÇ ÅäÇÈ Ãëµæ¿¡ ½ÇÆÐÇßÀ» °æ¿ìpublic boolean getNoLocal() throws JMSException
NoLocal
¼Ó¼ºÀ» ÃëµæÇÕ´Ï´Ù. ÀÌ ¼Ó¼ºÀÇ µðÆúƮġ´Â false ÀÔ´Ï´Ù. JMSException
- ³»ºÎ ¿¡·¯¸¦ À§Çؼ(¶§¹®¿¡) JMS ÇÁ·Î¹ÙÀÌ´õ°¡ ÀÌ Æ®ÇÈÅ©»çºê½ºÅ©¶óÀ̹ÙÀÇ NoLocal
¼Ó¼º Ãëµæ¿¡ ½ÇÆÐÇßÀ» °æ¿ì
|
|||||||||
ÀüÀÇ Å¬·¡½º ´ÙÀ½ÀÇ Å¬·¡½º | ÇÁ·¹ÀÓ ÀÖ¾î ÇÁ·¹ÀÓ ¾øÀ½ | ||||||||
°³¿ä: ³»ºÎ Ŭ·¡½º | Çʵå | constructor¡¡ ¡¡ | ¸Þ¼Òµå | »ó¼¼: Çʵå | constructor¡¡ ¡¡ | ¸Þ¼Òµå |