javax.jms
ÀÎÅÍÆäÀ̽º MessageConsumer

±âÁ¸ÀÇ ¼­ºê ÀÎÅÍÆäÀ̽ºÀÇ À϶÷:
QueueReceiver , TopicSubscriber

public interface MessageConsumer

Ŭ¶óÀÌ¾ðÆ®´Â,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 ¸¦ ¼³Á¤ÇÕ´Ï´Ù.
 

¸Þ¼ÒµåÀÇ »ó¼¼

getMessageSelector

public java.lang.String getMessageSelector()
                                    throws JMSException 
ÀÌ ¸Þ¼¼Áö ÄÁ½´¸Ó(consumer)ÀÇ ¸Þ¼¼Áö ½Ç·ºÅͽÄÀ» ÃëµæÇÕ´Ï´Ù.
¹Ýȯ°ª:
ÀÌ ¸Þ¼¼Áö ÄÁ½´¸Ó(consumer)ÀÇ ¸Þ¼¼Áö ½Ç·ºÅÍ. ¸Þ¼¼Áö ÄÁ½´¸Ó(consumer)¿ëÀÇ ¸Þ¼¼Áö ½Ç·ºÅͰ¡ Á¸ÀçÇÏÁö ¾Ê´Â (Áï, ¸Þ¼¼Áö ½Ç·ºÅͰ¡ ¹Ì¼³Á¤Àΰ¡, null ¶Ç´Â ÇÏ´ÃÀÇ Ä³¸¯ÅÍ ¶óÀÎÀ¸·Î ¼³Á¤µÇ¾î ÀÖÀ») °æ¿ì´Â null
¿¹¿Ü:
JMSException - ³»ºÎ ¿¡·¯¸¦ À§Çؼ­(¶§¹®¿¡) JMS ÇÁ·Î¹ÙÀÌ´õ°¡ ¸Þ¼¼Áö ½Ç·ºÅÍÀÇ Ãëµæ¿¡ ½ÇÆÐÇßÀ» °æ¿ì

getMessageListener

public MessageListener  getMessageListener()
                                   throws JMSException 
ÀÌ ¸Þ¼¼Áö ÄÁ½´¸Ó(consumer)ÀÇ MessageListener ¸¦ ÃëµæÇÕ´Ï´Ù.
¹Ýȯ°ª:
¸Þ¼¼Áö ÄÁ½´¸Ó(consumer)ÀÇ Ã»ÃëÀÚ ¶Ç´Â null (ûÃëÀÚ°¡ ¼³Á¤µÇ¾î ÀÖÁö ¾ÊÀº °æ¿ì)
¿¹¿Ü:
JMSException - ³»ºÎ ¿¡·¯¸¦ À§Çؼ­(¶§¹®¿¡) JMS ÇÁ·Î¹ÙÀÌ´õ°¡ ¸Þ¼¼Áö ûÃëÀÚÀÇ Ãëµæ¿¡ ½ÇÆÐÇßÀ» °æ¿ì
°ü·Ã Ç׸ñ:
setMessageListener(javax.jms.MessageListener)

setMessageListener

public void setMessageListener(MessageListener  listener)
                        throws JMSException 
ÀÌ ¸Þ¼¼Áö ÄÁ½´¸Ó(consumer)ÀÇ MessageListener ¸¦ ¼³Á¤ÇÕ´Ï´Ù.

¸Þ¼¼Áö ûÃëÀÚ¸¦ null ·Î ¼³Á¤ÇÏ´Â °ÍÀº, ¸Þ¼¼Áö ÄÁ½´¸Ó(consumer)¿ëÀÇ ¸Þ¼¼Áö ûÃëÀÚÀÇ ¼³Á¤À» ÇØÁ¦ÇÏ´Â °ÍÀ¸·Î µî°¡ÀÔ´Ï´Ù.

±âÁ¸ÀÇ Ã»ÃëÀÚ¿¡ ÀÇÇØ ¸Þ¼¼Áö°¡ 󸮵ǰí ÀÖ´Â µ¿¾È, ¶Ç´Â ÄÁ½´¸Ó(consumer)¸¦ »ç¿ëÇØ ¸Þ¼¼ÁöÀÇ µ¿±âÀûÀΠ󸮸¦ Çϰí ÀÖ´Â µ¿¾È¿¡,MessageConsumer.setMessageListener ¸¦ È£ÃâÇßÀ» °æ¿ìÀÇ ¿µÇâ¿¡ ´ëÇØ¼­´Â Á¤Àǵǰí ÀÖÁö ¾Ê½À´Ï´Ù.

ÆÄ¶ó¹ÌÅÍ:
listener - ¸Þ¼¼Áö Àü´ÞóÀÇ Ã»ÃëÀÚ
¿¹¿Ü:
JMSException - ³»ºÎ ¿¡·¯¸¦ À§Çؼ­(¶§¹®¿¡) JMS ÇÁ·Î¹ÙÀÌ´õ°¡ ¸Þ¼¼Áö ûÃëÀÚÀÇ ¼³Á¤¿¡ ½ÇÆÐÇßÀ» °æ¿ì
°ü·Ã Ç׸ñ:
getMessageListener()

receive

public Message  receive()
                throws JMSException 
ÀÌ ¸Þ¼¼Áö ÄÁ½´¸Ó(consumer)¿ëÀ¸·Î »ý¼ºµÈ ´ÙÀ½ÀÇ ¸Þ¼¼Áö¸¦ ¼ö½ÅÇÕ´Ï´Ù.

¸Þ¼¼Áö°¡ »ý¼ºµÇ´ÂÁö, ÀÌ ¸Þ¼¼Áö ÄÁ½´¸Ó(consumer)°¡ ´ÝÇôÁú ¶§±îÁö, ÀÌ È£ÃâÀº ºí·ÏÀ» ½ÇÇàÇÕ´Ï´Ù.

Æ®·£Àè¼Ç(transaction) ³»ºÎ¿¡¼­ ÀÌ receive °¡ ½ÇÇàµÇ´Â °æ¿ì, ÄÁ½´¸Ó(consumer)´Â Æ®·£Àè¼Ç(transaction)°¡ À§Å¹µÉ ¶§±îÁö ¸Þ¼¼Áö¸¦ º¸°ü À¯ÁöÇÕ´Ï´Ù.

¹Ýȯ°ª:
ÀÌ ¸Þ¼¼Áö ÄÁ½´¸Ó(consumer)¿ëÀ¸·Î »ý¼ºµÇ´Â ´ÙÀ½ÀÇ ¸Þ¼¼Áö, ¶Ç´Â null (ÀÌ ¸Þ¼¼Áö ÄÁ½´¸Ó(consumer)°¡ µ¿½Ã¿¡ ´ÝÇôÁö´Â °æ¿ì)
¿¹¿Ü:
JMSException - ³»ºÎ ¿¡·¯¸¦ À§Çؼ­(¶§¹®¿¡) JMS ÇÁ·Î¹ÙÀÌ´õ°¡ ´ÙÀ½ÀÇ ¸Þ¼¼ÁöÀÇ ¼ö½Å¿¡ ½ÇÆÐÇßÀ» °æ¿ì

receive

public Message  receive(long timeout)
                throws JMSException 
ÁöÁ¤µÈ ŸÀÓ ¾Æ¿ô °£°Ý³»¿¡ µµÂøÇÏ´Â ´ÙÀ½ÀÇ ¸Þ¼¼Áö¸¦ ¼ö½ÅÇÕ´Ï´Ù.

¸Þ¼¼Áö°¡ µµÂøÇÏ´ÂÁö, ŸÀÓ ¾Æ¿ô¿¡ ÀÇÇØ, À¯È¿±â°£ Á¶°¢ÀÌ µÇ´ÂÁö, ÀÌ ¸Þ¼¼Áö ÄÁ½´¸Ó(consumer)°¡ ´ÝÇôÁú ¶§±îÁö, ÀÌ È£ÃâÀº ºí·ÏÀ» ½ÇÇàÇÕ´Ï´Ù. timeout ¸¦ Á¦·Î·Î ¼³Á¤Çϸé(ÀÚ) À¯È¿±â°£ Á¶°¢ÀÌ µÉ °ÍÀº ¾ø±â ¶§¹®¿¡, ÀÌ È£ÃâÀº ºí·ÏÀ» ¹«±âÇÑÀ¸·Î ½ÇÇàÇÕ´Ï´Ù.

ÆÄ¶ó¹ÌÅÍ:
timeout - ŸÀÓ ¾Æ¿ôÄ¡ (¹Ð¸® ¼¼ÄÁµå)
¹Ýȯ°ª:
ÀÌ ¸Þ¼¼Áö ÄÁ½´¸Ó(consumer)¿ëÀ¸·Î »ý¼ºµÇ´Â ´ÙÀ½ÀÇ ¸Þ¼¼Áö, ¶Ç´Â null (ŸÀÓ ¾Æ¿ô¿¡ ÀÇÇØ, À¯È¿±â°£ Á¶°¢ÀÌ µÇ´ÂÁö, ÀÌ ¸Þ¼¼Áö ÄÁ½´¸Ó(consumer)°¡ µ¿½Ã¿¡ ´ÝÇôÁö´Â °æ¿ì)
¿¹¿Ü:
JMSException - ³»ºÎ ¿¡·¯¸¦ À§Çؼ­(¶§¹®¿¡) JMS ÇÁ·Î¹ÙÀÌ´õ°¡ ´ÙÀ½ÀÇ ¸Þ¼¼ÁöÀÇ ¼ö½Å¿¡ ½ÇÆÐÇßÀ» °æ¿ì

receiveNoWait

public Message  receiveNoWait()
                      throws JMSException 
°ð¹Ù·Î ¼ö½Å °¡´ÉÇÑ °æ¿ì´Â, ´ÙÀ½ÀÇ ¸Þ¼¼Áö¸¦ ¼ö½ÅÇÕ´Ï´Ù.
¹Ýȯ°ª:
ÀÌ ¸Þ¼¼Áö ÄÁ½´¸Ó(consumer)¿ëÀ¸·Î »ý¼ºµÈ ´ÙÀ½ÀÇ ¸Þ¼¼Áö, ¶Ç´Â null (¼ö½Å °¡´ÉÇÑ ´ÙÀ½ÀÇ ¸Þ¼¼Áö°¡ Á¸ÀçÇÏÁö ¾Ê´Â °æ¿ì)
¿¹¿Ü:
JMSException - ³»ºÎ ¿¡·¯¸¦ À§Çؼ­(¶§¹®¿¡) JMS ÇÁ·Î¹ÙÀÌ´õ°¡ ´ÙÀ½ÀÇ ¸Þ¼¼ÁöÀÇ ¼ö½Å¿¡ ½ÇÆÐÇßÀ» °æ¿ì

close

public void close()
           throws JMSException 
¸Þ¼¼Áö ÄÁ½´¸Ó(consumer)¸¦ ´Ý½À´Ï´Ù.

ÇÁ·Î¹ÙÀÌ´õ´Â MessageConsumer ¿¡ ´ëÀÀÇÏ´Â ¸®¼Ò½º¸¦ Java °¡»ó ¸Ó½Å ¿ÜºÎ¿¡ ÇÒ´çÇÏ´Â °æ¿ì°¡ ÀÖ±â (À§ÇØ)¶§¹®¿¡, ÀÌ·¯ÇÑ ¸®¼Ò½º°¡ ºÒÇÊ¿äÇÏ°Ô µÇ¾úÀ» °æ¿ì, Ŭ¶óÀÌ¾ðÆ®°¡ ¸®¼Ò½º¸¦ ´ÝÀ» Çʿ䰡 ÀÖ½À´Ï´Ù. ÀÌ·¯ÇÑ ¸®¼Ò½ºÀÇ ÀçÀÌ¿ëÀ» °¡º£Áö ÄÝ·º¼Ç¿¡ ¸Ã°åÀ» °æ¿ì, ÀûÀýÇÑ Å¸Àֿ̹¡ ÀçÀÌ¿ëÀ» ÇÑ´Ù°í´Â ÇÒ ¼ö ¾ø½À´Ï´Ù.

receive ¶Ç´Â ½ÇÇàÁßÀÇ ¸Þ¼¼Áö ûÃëÀÚ°¡ ¿Ï·áÇÒ ¶§±îÁö, ÀÌ È£ÃâÀº ºí·ÏÀ» ½ÇÇàÇÕ´Ï´Ù. ÀÌ ¸Þ¼¼Áö ÄÁ½´¸Ó(consumer)°¡ ´ÝÇôÁö¸é(ÀÚ), ºí·Ï µÈ ¸Þ¼¼Áö ÄÁ½´¸Ó(consumer)ÀÇ receive È£ÃâÀÌ null ¸¦ µ¹·ÁÁÝ´Ï´Ù.

¿¹¿Ü:
JMSException - ³»ºÎ ¿¡·¯¸¦ À§Çؼ­(¶§¹®¿¡) JMS ÇÁ·Î¹ÙÀÌ´õ°¡ ÄÁ½´¸Ó(consumer)¸¦ ´Ý´Â 󸮿¡ ½ÇÆÐÇßÀ» °æ¿ì


Copyright 2002 Sun Microsystems, Inc. All rights reserved.
»ç¿ë¿¡´Â»ç¿ë Çã¶ô °è¾àÀÌ Àû¿ëµË´Ï´Ù.